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

This closes #360

This commit is contained in:
Clebert Suconic 2016-01-29 09:30:45 -05:00
parent 0d6e6a35f5 062a675a53
commit 37845ebe3e
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeFailoverTest.java
View File

@ -18,6 +18,7 @@ package org.apache.activemq.artemis.tests.integration.cluster.bridge;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.concurrent.TimeUnit;
import org.apache.activemq.artemis.api.core.client.ClientConsumer; import org.apache.activemq.artemis.api.core.client.ClientConsumer;
import org.apache.activemq.artemis.api.core.client.ClientMessage; import org.apache.activemq.artemis.api.core.client.ClientMessage;
@ -177,7 +178,7 @@ public class BridgeFailoverTest extends MultiServerTestBase {
locatorConsumer.close(); locatorConsumer.close();
waitForServerToStart(backupServers[4]); assertTrue("Backup server didn't activate.", backupServers[4].waitForActivation(5, TimeUnit.SECONDS));
for (int i = 100; i < 200; i++) { for (int i = 100; i < 200; i++) {
ClientMessage msg = session.createMessage(true); ClientMessage msg = session.createMessage(true);