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

NO-JIRA: Cleanup on Smoke test

This commit is contained in:
Clebert Suconic 2017-04-06 16:44:40 -04:00 committed by Justin Bertram
parent f5738243fd
commit 029132c1f4
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/replicationflow/ReplicationFlowControlTest.java
View File

@ -147,8 +147,17 @@ public class ReplicationFlowControlTest extends SmokeTestBase {
session.commit();
System.out.println("Awaiting all consumers to finish");
while (!latch.await(5, TimeUnit.SECONDS)) {
System.out.println("Missing " + latch.getCount() + ", totalConsumed = " + totalConsumed);
while (!latch.await(10, TimeUnit.SECONDS)) {
fail("couldn't receive all messages");
}
running.set(false);
for (Consumer consumer: consumers) {
consumer.join(10000);
if (consumer.isAlive()) {
consumer.interrupt();
}
}
} finally {
@ -257,6 +266,7 @@ public class ReplicationFlowControlTest extends SmokeTestBase {
}
} finally {
try {
session.commit();
connection.close();
} catch (Throwable ignored) {
}