Added test -- which fails at the moment :-(

Author: Steve Powell

src/com/rabbitmq/client/impl/Frame.java

@@ -297,6 +297,9 @@ else if(value instanceof byte[]) {
         else if(value instanceof List) {
             acc += 4 + arraySize((List<?>)value);
         }
+        else if(value instanceof Object[]) {
+            acc += 4 + arraySize((Object[])value);
+        }
         else if(value == null) {
         }
         else {
@@ -305,7 +308,7 @@ else if(value == null) {
         return acc;
     }
 
-    /** Computes the AMQP wire-protocol length of an encoded field-array */
+    /** Computes the AMQP wire-protocol length of an encoded field-array of type List<?> */
     public static long arraySize(List<?> values)
         throws UnsupportedEncodingException
     {
@@ -315,7 +318,16 @@ public static long arraySize(List<?> values)
         }
         return acc;
     }
-  
+
+    /** Computes the AMQP wire-protocol length of an encoded field-array of type Object[] */
+    public static long arraySize(Object[] values) throws UnsupportedEncodingException {
+        long acc = 0;
+        for (Object value : values) {
+            acc += fieldValueSize(value);
+        }
+        return acc;
+    }
+
     /** Computes the AMQP wire-protocol length of a protocol-encoded long string. */
     private static int longStrSize(String str)
         throws UnsupportedEncodingException

test/src/com/rabbitmq/client/test/functional/QueueLifecycle.java

@@ -18,14 +18,17 @@
 package com.rabbitmq.client.test.functional;
 
 import java.io.IOException;
+import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;
 
 import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.QueueingConsumer;
 import com.rabbitmq.client.test.BrokerTestCase;
 
-// Test queue auto-delete and exclusive semantics.
+/**
+ * Test queue auto-delete and exclusive semantics.
+ */
 public class QueueLifecycle extends BrokerTestCase {
 
     void verifyQueueExists(String name) throws IOException {
@@ -77,12 +80,13 @@ void verifyNotEquivalent(boolean durable, boolean exclusive,
         fail("Queue.declare should have been rejected as not equivalent");
     }
 
-    // From amqp-0-9-1.xml, for "passive" property, "equivalent" rule:
-    // "If not set and the queue exists, the server MUST check that the
-    // existing queue has the same values for durable, exclusive,
-    // auto-delete, and arguments fields. The server MUST respond with
-    // Declare-Ok if the requested queue matches these fields, and MUST
-    // raise a channel exception if not."
+    /** From amqp-0-9-1.xml, for "passive" property, "equivalent" rule:
+     * "If not set and the queue exists, the server MUST check that the
+     * existing queue has the same values for durable, exclusive,
+     * auto-delete, and arguments fields. The server MUST respond with
+     * Declare-Ok if the requested queue matches these fields, and MUST
+     * raise a channel exception if not."
+     */
     public void testQueueEquivalence() throws IOException {
         String q = "queue";
         channel.queueDeclare(q, false, false, false, null);
@@ -154,4 +158,13 @@ public void testExclusiveGoesWithConnection() throws IOException {
         verifyQueueMissing(name);
     }
 
+    public void testArgumentArrays() throws Exception {
+        Map<String, Object> args = new HashMap<String, Object>();
+        args.put("my-key", new String[]{"foo", "bar", "baz"});
+        String queueName = "argumentArraysQueue";
+        channel.queueDeclare(queueName, true, true, false, args).getQueue();
+        args = new HashMap<String, Object>();
+        args.put("my-key", Arrays.asList(new String[]{"foo", "bar", "baz"}));
+        verifyQueueExists(queueName);
+    }
 }