refactor

Author: Alexandru Scvortov

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

@@ -138,8 +138,7 @@ public void testConfirmQueueDelete()
 
         channel.queueDelete("confirm-test-noconsumer");
 
-        while (ackSet.size() > 0)
-            Thread.sleep(10);
+        waitAcks();
     }
 
     public void testConfirmQueuePurge()
@@ -149,26 +148,23 @@ public void testConfirmQueuePurge()
 
         channel.queuePurge("confirm-test-noconsumer");
 
-        while (ackSet.size() > 0)
-            Thread.sleep(10);
+        waitAcks();
     }
 
     public void testConfirmBasicReject()
         throws IOException, InterruptedException
     {
         basicRejectCommon(false);
 
-        while (ackSet.size() > 0)
-            Thread.sleep(10);
+        waitAcks();
     }
 
     public void testConfirmQueueTTL()
         throws IOException, InterruptedException
     {
         publishN("", "confirm-ttl", true, false, false);
 
-        while (ackSet.size() > 0)
-            Thread.sleep(10);
+        waitAcks();
     }
 
     public void testConfirmBasicRejectRequeue()
@@ -183,8 +179,7 @@ public void testConfirmBasicRejectRequeue()
         channel.basicConsume("confirm-test-noconsumer", true,
                              new DefaultConsumer(channel));
 
-        while (ackSet.size() > 0)
-            Thread.sleep(10);
+        waitAcks();
     }
 
     /* Publish NUM_MESSAGES persistent messages and wait for
@@ -196,8 +191,7 @@ public void confirmTest(String exchange, String queueName,
     {
         publishN(exchange, queueName, persistent, mandatory, immediate);
 
-        while (ackSet.size() > 0)
-            Thread.sleep(10);
+        waitAcks();
     }
 
     private void publishN(String exchangeName, String queueName,
@@ -242,4 +236,9 @@ private void basicRejectCommon(boolean requeue)
             channel.basicReject(dtag, requeue);
         }
     }
+
+    private void waitAcks() throws InterruptedException {
+        while (ackSet.size() > 0)
+            Thread.sleep(10);
+    }
 }