Introduce Channel#exchangeUnbindNoWait

Author: michaelklishin

src/com/rabbitmq/client/Channel.java

@@ -466,6 +466,17 @@ void exchangeDeclareNoWait(String exchange,
      */
     Exchange.UnbindOk exchangeUnbind(String destination, String source, String routingKey, Map<String, Object> arguments) throws IOException;
 
+    /**
+     * Same as {@link Channel#exchangeUnbind(String, String, String, java.util.Map)} but sets no-wait parameter to true
+     * and retuns nothing (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 exchangeUnbindNoWait(String destination, String source, String routingKey, Map<String, Object> arguments) throws IOException;
+
     /**
      * Actively declare a server-named exclusive, autodelete, non-durable queue.
      * The name of the new queue is held in the "queue" field of the {@link com.rabbitmq.client.AMQP.Queue.DeclareOk} result.

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

@@ -812,6 +812,19 @@ public Exchange.UnbindOk exchangeUnbind(String destination, String source,
         return exchangeUnbind(destination, source, routingKey, null);
     }
 
+    /** Public API - {@inheritDoc} */
+    public void exchangeUnbindNoWait(String destination, String source,
+                                     String routingKey, Map<String, Object> arguments)
+            throws IOException {
+        transmit(new AMQCommand(new Exchange.Unbind.Builder()
+                                 .destination(destination)
+                                 .source(source)
+                                 .routingKey(routingKey)
+                                 .arguments(arguments)
+                                 .nowait(true)
+                                 .build()));
+    }
+
     /** Public API - {@inheritDoc} */
     public Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive,
                                         boolean autoDelete, Map<String, Object> arguments)

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

@@ -243,6 +243,11 @@ public AMQP.Exchange.UnbindOk exchangeUnbind(String destination, String source,
         return delegate.exchangeUnbind(destination, source, routingKey, arguments);
     }
 
+    public void exchangeUnbindNoWait(String destination, String source, String routingKey, Map<String, Object> arguments) throws IOException {
+        delegate.exchangeUnbindNoWait(destination, source, routingKey, arguments);
+        deleteRecordedExchangeBinding(destination, source, routingKey, arguments);
+    }
+
     public AMQP.Queue.DeclareOk queueDeclare() throws IOException {
         return queueDeclare("", false, true, true, null);
     }

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

@@ -28,6 +28,17 @@ public void testExchangeDeclareWithNowait() throws IOException {
     }
 
     public void testExchangeBindWithNowait() throws IOException {
+        String x = generateExchangeName();
+        try {
+            channel.exchangeDeclare(x, "fanout", false, false, false, null);
+            channel.exchangeBind(x, "amq.fanout", "", null);
+            channel.exchangeUnbindNoWait(x, "amq.fanout", "", null);
+        } finally {
+            channel.exchangeDelete(x);
+        }
+    }
+
+    public void testExchangeUnbindWithNowait() throws IOException {
         String x = generateExchangeName();
         try {
             channel.exchangeDeclareNoWait(x, "fanout", false, false, false, null);