diff options
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/FieldTable.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/FieldTable.java b/java/common/src/main/java/org/apache/qpid/framing/FieldTable.java index 118de0fbbc..db3a5851ab 100644 --- a/java/common/src/main/java/org/apache/qpid/framing/FieldTable.java +++ b/java/common/src/main/java/org/apache/qpid/framing/FieldTable.java @@ -321,7 +321,7 @@ public class FieldTable public byte[] getBytes(AMQShortString string) { AMQTypedValue value = getProperty(string); - if (value != null && (value.getType() == AMQType.BINARY)) + if (value != null && (value.getType() == AMQType.BINARY || value.getType() == AMQType.LONG_STRING)) { return (byte[]) value.getValue(); } @@ -497,7 +497,9 @@ public class FieldTable public Object setBytes(AMQShortString string, byte[] bytes) { checkPropertyName(string); - return setProperty(string, AMQType.BINARY.asTypedValue(bytes)); + // HACK for interop + //return setProperty(string, AMQType.BINARY.asTypedValue(bytes)); + return setProperty(string, AMQType.LONG_STRING.asTypedValue(bytes)); } public Object setBytes(String string, byte[] bytes, int start, int length) |