ARTEMIS-2755 Add SoakPagingTest timeouts

Limit time awaiting producers and consumers.
apache · May 11, 2020 · b43f888 · b43f888
1 parent 56f2654
commit b43f888
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/...src/test/java/org/apache/activemq/artemis/tests/smoke/replicationflow/SoakPagingTest.java b/...src/test/java/org/apache/activemq/artemis/tests/smoke/replicationflow/SoakPagingTest.java
@@ -28,6 +28,7 @@
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 
 import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase;
@@ -157,10 +158,16 @@ public void run() {
          }
 
          System.out.println("Awaiting producers...");
-         producersLatch.await();
+         if (!producersLatch.await(30000, TimeUnit.MILLISECONDS)) {
+            System.err.println("Awaiting producers timeout");
+            System.exit(0);
+         }
 
          System.out.println("Awaiting consumers...");
-         consumersLatch.await();
+         if (!consumersLatch.await(30000, TimeUnit.MILLISECONDS)) {
+            System.err.println("Awaiting consumers timeout");
+            System.exit(0);
+         }
 
          System.out.println("Awaiting timeout...");
          Thread.sleep(time);