Wait for a single ack/nack in this test, it is sufficient

Author: michaelklishin

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

@@ -127,8 +127,7 @@ public void handleReturn(int replyCode, String replyText, String exchange,
     }
 
     public void testConfirmListenerRecovery() throws IOException, InterruptedException, TimeoutException {
-        int n = 3;
-        final CountDownLatch latch = new CountDownLatch(n);
+        final CountDownLatch latch = new CountDownLatch(1);
         channel.addConfirmListener(new ConfirmListener() {
             public void handleAck(long deliveryTag, boolean multiple) throws IOException {
                 latch.countDown();
@@ -142,7 +141,7 @@ public void handleNack(long deliveryTag, boolean multiple) throws IOException {
         closeAndWaitForRecovery();
         expectChannelRecovery(channel);
         channel.confirmSelect();
-        for (int i = 0; i < n * 20; i++) {
+        for (int i = 0; i < 1000; i++) {
             channel.basicPublish("", q, true, false, null, "mandatory1".getBytes());
         }
         waitForConfirms(channel);