Introduce Channel#exchangeBindNowait

Author: michaelklishin

src/com/rabbitmq/client/Channel.java

@@ -418,6 +418,17 @@ void exchangeDeclareNowait(String exchange,
      */
     Exchange.BindOk exchangeBind(String destination, String source, String routingKey, Map<String, Object> arguments) throws IOException;
 
+    /**
+     * Like {@link Channel#exchangeBind(String, String, String, java.util.Map)} but sets nowait parameter
+     * to true and returns void (as there will be no response from the server).
+     * @param destination the name of the exchange to which messages flow across the binding
+     * @param source the name of the exchange from which messages flow across the binding
+     * @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 exchangeBindNowait(String destination, String source, String routingKey, Map<String, Object> arguments) throws IOException;
+
     /**
      * Unbind an exchange from an exchange, with no extra arguments.
      * @see com.rabbitmq.client.AMQP.Exchange.Bind

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

@@ -763,6 +763,20 @@ public Exchange.BindOk exchangeBind(String destination, String source,
                .getMethod();
     }
 
+    /** Public API - {@inheritDoc} */
+    public void exchangeBindNowait(String destination,
+                                   String source,
+                                   String routingKey,
+                                   Map<String, Object> arguments) throws IOException {
+        transmit(new AMQCommand(new Exchange.Bind.Builder()
+                                .destination(destination)
+                                .source(source)
+                                .routingKey(routingKey)
+                                .arguments(arguments)
+                                .nowait(true)
+                                .build()));
+    }
+
     /** Public API - {@inheritDoc} */
     public Exchange.BindOk exchangeBind(String destination, String source,
             String routingKey) throws IOException {

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

@@ -218,6 +218,11 @@ public AMQP.Exchange.BindOk exchangeBind(String destination, String source, Stri
         return ok;
     }
 
+    public void exchangeBindNowait(String destination, String source, String routingKey, Map<String, Object> arguments) throws IOException {
+        delegate.exchangeBindNowait(destination, source, routingKey, arguments);
+        recordExchangeBinding(destination, source, routingKey, arguments);
+    }
+
     public AMQP.Exchange.UnbindOk exchangeUnbind(String destination, String source, String routingKey) throws IOException {
         return exchangeUnbind(destination, source, routingKey, null);
     }

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

@@ -26,4 +26,15 @@ public void testExchangeDeclareWithNowait() throws IOException {
             channel.exchangeDelete(x);
         }
     }
+
+    public void testExchangeBindWithNowait() throws IOException {
+        String x = generateExchangeName();
+        try {
+            channel.exchangeDeclareNowait(x, "fanout", false, false, false, null);
+            channel.exchangeBindNowait(x, "amq.fanout", "", null);
+        } finally {
+            channel.exchangeDelete(x);
+        }
+    }
+
 }