Test headers exchange validation.

Author: Simon MacMullen

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

@@ -72,5 +72,6 @@ public static void add(TestSuite suite) {
         suite.addTestSuite(InternalExchange.class);
         suite.addTestSuite(CcRoutes.class);
         suite.addTestSuite(WorkPoolTests.class);
+        suite.addTestSuite(HeadersExchangeValidation.class);
     }
 }

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

@@ -0,0 +1,48 @@
+package com.rabbitmq.client.test.functional;
+
+import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.test.BrokerTestCase;
+
+import java.io.IOException;
+import java.util.HashMap;
+
+public class HeadersExchangeValidation extends BrokerTestCase {
+
+    public void testHeadersValidation() throws IOException
+    {
+        AMQP.Queue.DeclareOk ok = channel.queueDeclare();
+        String queue = ok.getQueue();
+
+        HashMap<String, Object> arguments = new HashMap<String, Object>();
+        failBind(queue, arguments);
+
+        arguments.put("x-match", 23);
+        failBind(queue, arguments);
+
+        arguments.put("x-match", "all or any I don't mind");
+        failBind(queue, arguments);
+
+        arguments.put("x-match", "all");
+        succeedBind(queue, arguments);
+
+        arguments.put("x-match", "any");
+        succeedBind(queue, arguments);
+    }
+
+    private void failBind(String queue, HashMap<String, Object> arguments) {
+        try {
+            Channel ch = connection.createChannel();
+            ch.queueBind(queue, "amq.headers", "", arguments);
+            fail("Expected failure");
+        } catch (IOException e) {
+	        checkShutdownSignal(AMQP.PRECONDITION_FAILED, e);
+        }
+    }
+
+    private void succeedBind(String queue, HashMap<String, Object> arguments) throws IOException {
+        Channel ch = connection.createChannel();
+        ch.queueBind(queue, "amq.headers", "", arguments);
+        ch.close();
+    }
+}