You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2017/05/03 13:18:20 UTC
qpid-broker-j git commit: QPID-7766: [Java Broker] [Derby Store]
Unsigned byte type should be used when reading stored message metada type
Repository: qpid-broker-j
Updated Branches:
refs/heads/master d9afda2db -> 593d15778
QPID-7766: [Java Broker] [Derby Store] Unsigned byte type should be used when reading stored message metada type
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/593d1577
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/593d1577
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/593d1577
Branch: refs/heads/master
Commit: 593d157782d0080ecce2a744c649a050f969738e
Parents: d9afda2
Author: Alex Rudyy <or...@apache.org>
Authored: Wed May 3 14:16:30 2017 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Wed May 3 14:17:05 2017 +0100
----------------------------------------------------------------------
.../apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/593d1577/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java
----------------------------------------------------------------------
diff --git a/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java b/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java
index ad4acbc..ff7e2ad 100644
--- a/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java
+++ b/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java
@@ -1001,7 +1001,8 @@ public abstract class AbstractJDBCMessageStore implements MessageStore
QpidByteBuffer buf = QpidByteBuffer.wrap(dataAsBytes);
buf.position(1);
buf = buf.slice();
- MessageMetaDataType type = MessageMetaDataTypeRegistry.fromOrdinal(dataAsBytes[0]);
+ int typeOrdinal = dataAsBytes[0] & 0xff;;
+ MessageMetaDataType type = MessageMetaDataTypeRegistry.fromOrdinal(typeOrdinal);
StorableMessageMetaData metaData = type.createMetaData(buf);
buf.dispose();
return metaData;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org