Introduce Channel#queueBindNowait, commit missing test file

Author: michaelklishin

src/com/rabbitmq/client/Channel.java

@@ -507,6 +507,18 @@ Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive, b
      */
     Queue.BindOk queueBind(String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;
 
+    /**
+     * Same as {@link Channel#queueDeclare(String, boolean, boolean, boolean, java.util.Map)} but sets nowait
+     * parameter to true and returns void (as there will be no response
+     * from the server).
+     * @param queue the name of the queue
+     * @param exchange the name of the exchange
+     * @param routingKey the routine key to use for the binding
+     * @param arguments other properties (binding parameters)
+     * @throws java.io.IOException if an error is encountered
+     */
+    void queueBindNowait(String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;
+
     /**
      * Unbinds a queue from an exchange, with no extra arguments.
      * @see com.rabbitmq.client.AMQP.Queue.Unbind

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

@@ -851,6 +851,19 @@ public Queue.BindOk queueBind(String queue, String exchange, String routingKey)
         return queueBind(queue, exchange, routingKey, null);
     }
 
+    /** Public API - {@inheritDoc} */
+    public void queueBindNowait(String queue,
+                                String exchange,
+                                String routingKey,
+                                Map<String, Object> arguments) throws IOException {
+        transmit(new AMQCommand(new Queue.Bind.Builder()
+                                .queue(queue)
+                                .exchange(exchange)
+                                .routingKey(routingKey)
+                                .arguments(arguments)
+                                .build()));
+    }
+
     /** Public API - {@inheritDoc} */
     public Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey,
                                       Map<String, Object> arguments)

src/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java

@@ -263,6 +263,11 @@ public AMQP.Queue.BindOk queueBind(String queue, String exchange, String routing
         return ok;
     }
 
+    public void queueBindNowait(String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException {
+        delegate.queueBindNowait(queue, exchange, routingKey, arguments);
+        recordQueueBinding(queue, exchange, routingKey, arguments);
+    }
+
     public AMQP.Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey) throws IOException {
         return queueUnbind(queue, exchange, routingKey, null);
     }

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

@@ -0,0 +1,29 @@
+package com.rabbitmq.client.test.functional;
+
+import com.rabbitmq.client.test.BrokerTestCase;
+
+import java.io.IOException;
+
+public class Nowait extends BrokerTestCase {
+    public void testQueueDeclareWithNowait() throws IOException {
+        String q = generateQueueName();
+        channel.queueDeclareNowait(q, false, true, true, null);
+        channel.queueDeclarePassive(q);
+    }
+
+    public void testQueueBindWithNowait() throws IOException {
+        String q = generateQueueName();
+        channel.queueDeclareNowait(q, false, true, true, null);
+        channel.queueBindNowait(q, "amq.fanout", "", null);
+    }
+
+    public void testExchangeDeclareWithNowait() throws IOException {
+        String x = generateExchangeName();
+        try {
+            channel.exchangeDeclareNowait(x, "fanout", false, false, false, null);
+            channel.exchangeDeclarePassive(x);
+        } finally {
+            channel.exchangeDelete(x);
+        }
+    }
+}