diff options
| author | Robert Gemmell <robbie@apache.org> | 2012-02-17 11:57:45 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2012-02-17 11:57:45 +0000 |
| commit | fcabbae6796d4a28b1bb275e1e2995ec2bc875bd (patch) | |
| tree | 75982899fdbc9e8f245d8e54dfae16c51898a2fd | |
| parent | cd25c53b5f790b1338a1e557f3d360596ef2291b (diff) | |
| download | qpid-python-fcabbae6796d4a28b1bb275e1e2995ec2bc875bd.tar.gz | |
QPID-3743: remove try-catch block on converting BDB message meta data entry into StorableMessageMetaData
Applied patch from Oleksandr Rudyy <orudyy@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1245417 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuples/MessageMetaDataTB_5.java | 29 |
1 files changed, 9 insertions, 20 deletions
diff --git a/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuples/MessageMetaDataTB_5.java b/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuples/MessageMetaDataTB_5.java index cb6a623038..4e124a03e3 100644 --- a/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuples/MessageMetaDataTB_5.java +++ b/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuples/MessageMetaDataTB_5.java @@ -22,7 +22,6 @@ package org.apache.qpid.server.store.berkeleydb.tuples; import com.sleepycat.bind.tuple.TupleInput; import com.sleepycat.bind.tuple.TupleOutput; -import org.apache.log4j.Logger; import org.apache.qpid.server.store.MessageMetaDataType; import org.apache.qpid.server.store.StorableMessageMetaData; @@ -32,31 +31,21 @@ import org.apache.qpid.server.store.StorableMessageMetaData; */ public class MessageMetaDataTB_5 extends MessageMetaDataTB_4 { - private static final Logger _log = Logger.getLogger(MessageMetaDataTB_5.class); @Override public Object entryToObject(TupleInput tupleInput) { - try - { - final int bodySize = tupleInput.readInt(); - byte[] dataAsBytes = new byte[bodySize]; - tupleInput.readFast(dataAsBytes); + final int bodySize = tupleInput.readInt(); + byte[] dataAsBytes = new byte[bodySize]; + tupleInput.readFast(dataAsBytes); - java.nio.ByteBuffer buf = java.nio.ByteBuffer.wrap(dataAsBytes); - buf.position(1); - buf = buf.slice(); - MessageMetaDataType type = MessageMetaDataType.values()[dataAsBytes[0]]; - StorableMessageMetaData metaData = type.getFactory().createMetaData(buf); + java.nio.ByteBuffer buf = java.nio.ByteBuffer.wrap(dataAsBytes); + buf.position(1); + buf = buf.slice(); + MessageMetaDataType type = MessageMetaDataType.values()[dataAsBytes[0]]; + StorableMessageMetaData metaData = type.getFactory().createMetaData(buf); - return metaData; - } - catch (Exception e) - { - _log.error("Error converting entry to object: " + e, e); - // annoyingly just have to return null since we cannot throw - return null; - } + return metaData; } @Override |
