Test queue recovery with no-wait = true

Author: michaelklishin

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

@@ -176,6 +176,16 @@ public void testClientNamedQueueRecovery() throws IOException, InterruptedExcept
         ch.queueDelete(q);
     }
 
+    public void testClientNamedQueueRecoveryWithNoWait() throws IOException, InterruptedException, TimeoutException {
+        Channel ch = connection.createChannel();
+        String q = "java-client.test.recovery.q1-nowait";
+        declareClientNamedQueueNoWait(ch, q);
+        closeAndWaitForRecovery();
+        expectChannelRecovery(ch);
+        expectQueueRecovery(ch, q);
+        ch.queueDelete(q);
+    }
+
     public void testServerNamedQueueRecovery() throws IOException, InterruptedException {
         String q = channel.queueDeclare("", false, false, false, null).getQueue();
         String x = "amq.fanout";
@@ -377,6 +387,10 @@ private AMQP.Queue.DeclareOk declareClientNamedQueue(Channel ch, String q) throw
         return ch.queueDeclare(q, true, false, false, null);
     }
 
+    private void declareClientNamedQueueNoWait(Channel ch, String q) throws IOException {
+        ch.queueDeclareNoWait(q, true, false, false, null);
+    }
+
     private AMQP.Exchange.DeclareOk declareExchange(Channel ch, String x) throws IOException {
         return ch.exchangeDeclare(x, "fanout", false);
     }