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 | 9571094314a2896b1b53cc93b5543656e0e3cd2f (patch) | |
tree | 75982899fdbc9e8f245d8e54dfae16c51898a2fd | |
parent | 400452421c0ff884cdf03b47bc4cb770e01ac274 (diff) | |
download | qpid-python-9571094314a2896b1b53cc93b5543656e0e3cd2f.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 |