Introduce Channel#exchangeDeleteNowait

Author: michaelklishin

src/com/rabbitmq/client/Channel.java

@@ -383,6 +383,18 @@ void exchangeDeclareNowait(String exchange,
      */
     Exchange.DeleteOk exchangeDelete(String exchange, boolean ifUnused) throws IOException;
 
+    /**
+     * Like {@link Channel#exchangeDelete(String, boolean)} but sets nowait parameter to true
+     * and returns void (as there will be no response from the server).
+     * @see com.rabbitmq.client.AMQP.Exchange.Delete
+     * @see com.rabbitmq.client.AMQP.Exchange.DeleteOk
+     * @param exchange the name of the exchange
+     * @param ifUnused true to indicate that the exchange is only to be deleted if it is unused
+     * @throws java.io.IOException if an error is encountered
+     */
+    void exchangeDeleteNowait(String exchange, boolean ifUnused) throws IOException;
+
+
     /**
      * Delete an exchange, without regard for whether it is in use or not
      * @see com.rabbitmq.client.AMQP.Exchange.Delete

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

@@ -742,6 +742,15 @@ public Exchange.DeleteOk exchangeDelete(String exchange, boolean ifUnused)
             .getMethod();
     }
 
+    /** Public API - {@inheritDoc} */
+    public void exchangeDeleteNowait(String exchange, boolean ifUnused) throws IOException {
+        transmit(new AMQCommand(new Exchange.Delete.Builder()
+                                        .exchange(exchange)
+                                        .ifUnused(ifUnused)
+                                        .nowait(true)
+                                        .build()));
+    }
+
     /** Public API - {@inheritDoc} */
     public Exchange.DeleteOk exchangeDelete(String exchange)
         throws IOException

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

@@ -204,6 +204,11 @@ public AMQP.Exchange.DeleteOk exchangeDelete(String exchange, boolean ifUnused)
         return delegate.exchangeDelete(exchange, ifUnused);
     }
 
+    public void exchangeDeleteNowait(String exchange, boolean ifUnused) throws IOException {
+        deleteRecordedExchange(exchange);
+        delegate.exchangeDeleteNowait(exchange, ifUnused);
+    }
+
     public AMQP.Exchange.DeleteOk exchangeDelete(String exchange) throws IOException {
         return exchangeDelete(exchange, false);
     }

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

@@ -43,4 +43,9 @@ public void testQueueDeleteWithNowait() throws IOException {
         channel.queueDeleteNowait(q, false, false);
     }
 
+    public void testExchangeDeleteWithNowait() throws IOException {
+        String x = generateExchangeName();
+        channel.exchangeDeclareNowait(x, "fanout", false, false, false, null);
+        channel.exchangeDeleteNowait(x, false);
+    }
 }