* uses LONG_STRING in place of WIDE_STRING for properties set through FieldTable.setString() as these appear to all be equivalent (apart from the type code)

* uses setString instead of setAsciiString in creation of the connection.start-ok frames client properties

* uses 4 bytes for the size of the BINARY value type as per the spec posted on the wiki 



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@497352 13f79535-47bb-0310-9956-ffa450edef68

3 files changed, 5 insertions, 14 deletions

diff --git a/java/common/src/main/java/org/apache/qpid/framing/AMQType.java b/java/common/src/main/java/org/apache/qpid/framing/AMQType.java
index 23c1929205..5175eace1e 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/AMQType.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/AMQType.java
@@ -230,7 +230,7 @@ public enum AMQType
     {

         public int getEncodingSize(Object value)

         {

-            return 1 + (value == null ? 0 : ((byte[]) value).length);

+            return EncodingUtils.encodedLongstrLength((byte[]) value);

         }

 

 

@@ -250,12 +250,12 @@ public enum AMQType
 

         public void writeValueImpl(Object value, ByteBuffer buffer)

         {

-            EncodingUtils.writeBytes(buffer, (byte[]) value);            

+            EncodingUtils.writeLongstr(buffer, (byte[]) value);            

         }

 

         public Object readValueFromBuffer(ByteBuffer buffer)

         {

-            return EncodingUtils.readBytes(buffer);

+            return EncodingUtils.readLongstr(buffer);

         }

 

     },

diff --git a/java/common/src/main/java/org/apache/qpid/framing/EncodingUtils.java b/java/common/src/main/java/org/apache/qpid/framing/EncodingUtils.java
index c4d568ba88..339f83588d 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/EncodingUtils.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/EncodingUtils.java
@@ -747,7 +747,7 @@ public class EncodingUtils
         }
     }
 
-    public static byte[] readLongstr(ByteBuffer buffer) throws AMQFrameDecodingException
+    public static byte[] readLongstr(ByteBuffer buffer)
     {
         long length = buffer.getUnsignedInt();
         if (length == 0)
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 147601b9f9..1a72910536 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
@@ -448,7 +448,6 @@ public class FieldTable
         {
             return setProperty(string, AMQType.ASCII_STRING.asTypedValue(value));
         }
-
     }
 
     public Object setString(AMQShortString string, String value)
@@ -460,15 +459,7 @@ public class FieldTable
         }
         else
         {
-            //FIXME: determine string encoding and set either WIDE or ASCII string
-//            if ()
-            {
-                return setProperty(string, AMQType.WIDE_STRING.asTypedValue(value));
-            }
-//            else
-//            {
-//                return setProperty(string, AMQType.ASCII_STRING.asTypedValue(value));
-//            }
+            return setProperty(string, AMQType.LONG_STRING.asTypedValue(value));
         }
     }