You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2018/07/25 15:18:08 UTC
activemq-artemis git commit: NO-JIRA fixing checkstyle
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 <cl...@apache.org>
Authored: Wed Jul 25 11:17:58 2018 -0400
Committer: Clebert Suconic <cl...@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());