diff options
author | Robert Greig <rgreig@apache.org> | 2007-01-16 17:29:24 +0000 |
---|---|---|
committer | Robert Greig <rgreig@apache.org> | 2007-01-16 17:29:24 +0000 |
commit | 469be448d433c6cb81c498aae56207adfafee866 (patch) | |
tree | 73e2f2f1c76fb26ed8f9e75b2262bd13d5ebdca3 /java/common | |
parent | 6bd699c9e392eb83f837c4863989c32e7afcf3fe (diff) | |
download | qpid-python-469be448d433c6cb81c498aae56207adfafee866.tar.gz |
QPID-245 reverted interop changes for the sake of JMS compliance.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@496785 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common')
-rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/FieldTable.java | 25 |
1 files changed, 10 insertions, 15 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 db3a5851ab..147601b9f9 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 @@ -278,8 +278,7 @@ public class FieldTable { AMQTypedValue value = getProperty(string); if ((value != null) && ((value.getType() == AMQType.WIDE_STRING) || - (value.getType() == AMQType.ASCII_STRING || - (value.getType() == AMQType.LONG_STRING)))) + (value.getType() == AMQType.ASCII_STRING))) { return (String) value.getValue(); } @@ -321,7 +320,7 @@ public class FieldTable public byte[] getBytes(AMQShortString string) { AMQTypedValue value = getProperty(string); - if (value != null && (value.getType() == AMQType.BINARY || value.getType() == AMQType.LONG_STRING)) + if (value != null && (value.getType() == AMQType.BINARY)) { return (byte[]) value.getValue(); } @@ -365,7 +364,7 @@ public class FieldTable public Object setByte(String string, byte b) { return setByte(new AMQShortString(string), b); - } + } public Object setByte(AMQShortString string, byte b) { @@ -447,16 +446,14 @@ public class FieldTable } else { - return setProperty(string, AMQType.LONG_STRING.asTypedValue(value)); + return setProperty(string, AMQType.ASCII_STRING.asTypedValue(value)); } } public Object setString(AMQShortString string, String value) { - // temporary for interop until field table types are standardised - return setAsciiString(string, value); - /*checkPropertyName(string); + checkPropertyName(string); if (value == null) { return setProperty(string, AMQType.VOID.asTypedValue(null)); @@ -472,7 +469,7 @@ public class FieldTable // { // return setProperty(string, AMQType.ASCII_STRING.asTypedValue(value)); // } - } */ + } } @@ -497,9 +494,7 @@ public class FieldTable public Object setBytes(AMQShortString string, byte[] bytes) { checkPropertyName(string); - // HACK for interop - //return setProperty(string, AMQType.BINARY.asTypedValue(bytes)); - return setProperty(string, AMQType.LONG_STRING.asTypedValue(bytes)); + return setProperty(string, AMQType.BINARY.asTypedValue(bytes)); } public Object setBytes(String string, byte[] bytes, int start, int length) @@ -653,7 +648,7 @@ public class FieldTable } } - + // ************************* Byte Buffer Processing public void writeToBuffer(ByteBuffer buffer) @@ -828,7 +823,7 @@ public class FieldTable public void clear() { initMapIfNecessary(); - _encodedForm = null; + _encodedForm = null; _properties.clear(); _encodedSize = 0; } @@ -919,7 +914,7 @@ public class FieldTable _properties.put(key,value); - + } while (buffer.remaining() > expectedRemaining); |