Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-2755 Add SoakPagingTest timeouts 

Limit time awaiting producers and consumers.
This commit is contained in:
brusdev 2020-05-10 21:08:23 +02:00 committed by Clebert Suconic
parent 56f2654cbb
commit b43f888ce2
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/replicationflow/SoakPagingTest.java
View File

@ -28,6 +28,7 @@ import javax.jms.Topic;
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 class SoakPagingTest extends SmokeTestBase {
}
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);