Repository: activemq-artemis Updated Branches: refs/heads/2.6.x 47d33f3a7 -> 81e799cd2
NO-JIRA fixing checkstyle Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/81e799cd Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/81e799cd Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/81e799cd Branch: refs/heads/2.6.x Commit: 81e799cd23700d90c0bda9dd1d83d95609bb6d64 Parents: 47d33f3 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Wed Jul 25 11:17:58 2018 -0400 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Wed Jul 25 11:17:58 2018 -0400 ---------------------------------------------------------------------- .../replication/SharedNothingReplicationFlowControlTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/81e799cd/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationFlowControlTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationFlowControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationFlowControlTest.java index 5508c94..8fca577 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationFlowControlTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationFlowControlTest.java @@ -74,6 +74,7 @@ import org.apache.activemq.artemis.spi.core.security.jaas.InVMLoginModule; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.utils.ExecutorFactory; import org.jboss.logging.Logger; +import org.junit.After; import org.junit.Assert; import org.junit.Before; import org.junit.Rule; @@ -103,7 +104,7 @@ public class SharedNothingReplicationFlowControlTest extends ActiveMQTestBase { public void testReplicationIfFlowControlled() throws Exception { // start live Configuration liveConfiguration = createLiveConfiguration(); - ActiveMQServer liveServer = ActiveMQServers.newActiveMQServer(liveConfiguration); + ActiveMQServer liveServer = addServer(ActiveMQServers.newActiveMQServer(liveConfiguration)); liveServer.start(); Wait.waitFor(() -> liveServer.isStarted()); @@ -117,14 +118,13 @@ public class SharedNothingReplicationFlowControlTest extends ActiveMQTestBase { sess.createQueue("flowcontrol", RoutingType.ANYCAST, "flowcontrol", true); sess.close(); -Executor sendMessageExecutor = Executors.newCachedThreadPool(); int i = 0; final int j = 100; final CountDownLatch allMessageSent = new CountDownLatch(j); // start backup Configuration backupConfiguration = createBackupConfiguration(); - ActiveMQServer backupServer = ActiveMQServers.newActiveMQServer(backupConfiguration); + ActiveMQServer backupServer = addServer(ActiveMQServers.newActiveMQServer(backupConfiguration)); backupServer.start(); Wait.waitFor(() -> backupServer.isStarted());