This closes #386

apache · Feb 10, 2016 · 66085ae · 66085ae
2 parents ece5d81 + ce906c8
commit 66085ae
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java b/...-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java
@@ -790,10 +790,10 @@ public void testDeleteQueueRestart() throws Exception {
       producer.close();
       session.start();
 
-      long timeout = System.currentTimeMillis() + 10000;
+      long timeout = System.currentTimeMillis() + 30000;
 
       // I want the buffer full to make sure there are pending messages on the server's side
-      while (System.currentTimeMillis() < timeout && cons.getBufferSize() < 1000 && cons2.getBufferSize() < 1000) {
+      while (System.currentTimeMillis() < timeout && (cons.getBufferSize() < 1000 || cons2.getBufferSize() < 1000)) {
          System.out.println("cons1 buffer = " + cons.getBufferSize() + ", cons2 buffer = " + cons2.getBufferSize());
          Thread.sleep(100);
       }