Introduce Channel#queueDeleteNowait

Author: michaelklishin

src/com/rabbitmq/client/Channel.java

@@ -528,6 +528,18 @@ void queueDeclareNowait(String queue, boolean durable, boolean exclusive, boolea
      */
     Queue.DeleteOk queueDelete(String queue, boolean ifUnused, boolean ifEmpty) throws IOException;
 
+    /**
+     * Like {@link Channel#queueDelete(String, boolean, boolean)} but sets nowait parameter
+     * to true and returns nothing (as there will be no response from the server).
+     * @see com.rabbitmq.client.AMQP.Queue.Delete
+     * @see com.rabbitmq.client.AMQP.Queue.DeleteOk
+     * @param queue the name of the queue
+     * @param ifUnused true if the queue should be deleted only if not in use
+     * @param ifEmpty true if the queue should be deleted only if empty
+     * @throws java.io.IOException if an error is encountered
+     */
+    void queueDeleteNowait(String queue, boolean ifUnused, boolean ifEmpty) throws IOException;
+
     /**
      * Bind a queue to an exchange, with no extra arguments.
      * @see com.rabbitmq.client.AMQP.Queue.Bind

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

@@ -870,6 +870,16 @@ public Queue.DeleteOk queueDelete(String queue, boolean ifUnused, boolean ifEmpt
                .getMethod();
     }
 
+    @Override
+    public void queueDeleteNowait(String queue, boolean ifUnused, boolean ifEmpty) throws IOException {
+        transmit(new AMQCommand(new Queue.Delete.Builder()
+                                        .queue(queue)
+                                        .ifUnused(ifUnused)
+                                        .ifEmpty(ifEmpty)
+                                        .nowait(true)
+                                        .build()));
+    }
+
     /** Public API - {@inheritDoc} */
     public Queue.DeleteOk queueDelete(String queue)
         throws IOException

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

@@ -278,6 +278,12 @@ public AMQP.Queue.DeleteOk queueDelete(String queue, boolean ifUnused, boolean i
         return delegate.queueDelete(queue, ifUnused, ifEmpty);
     }
 
+    @Override
+    public void queueDeleteNowait(String queue, boolean ifUnused, boolean ifEmpty) throws IOException {
+        deleteRecordedQueue(queue);
+        delegate.queueDeleteNowait(queue, ifUnused, ifEmpty);
+    }
+
     public AMQP.Queue.BindOk queueBind(String queue, String exchange, String routingKey) throws IOException {
         return queueBind(queue, exchange, routingKey, null);
     }

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

@@ -37,4 +37,10 @@ public void testExchangeBindWithNowait() throws IOException {
         }
     }
 
+    public void testQueueDeleteWithNowait() throws IOException {
+        String q = generateQueueName();
+        channel.queueDeclareNowait(q, false, true, true, null);
+        channel.queueDeleteNowait(q, false, false);
+    }
+
 }