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 2019/06/21 13:34:33 UTC
[activemq-artemis] branch master updated: ARTEMIS-2338 Adding Wait
clauses on QuorumFailOverLiveVotesTest
This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/master by this push:
new d1edb8d ARTEMIS-2338 Adding Wait clauses on QuorumFailOverLiveVotesTest
d1edb8d is described below
commit d1edb8d6e233199f9443b5b9a54ac279cae7626b
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Fri Jun 21 09:21:52 2019 -0400
ARTEMIS-2338 Adding Wait clauses on QuorumFailOverLiveVotesTest
---
.../integration/cluster/failover/QuorumFailOverLiveVotesTest.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/QuorumFailOverLiveVotesTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/QuorumFailOverLiveVotesTest.java
index ded54d2..93c0db5 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/QuorumFailOverLiveVotesTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/QuorumFailOverLiveVotesTest.java
@@ -24,6 +24,7 @@ import org.apache.activemq.artemis.core.config.ha.ReplicaPolicyConfiguration;
import org.apache.activemq.artemis.core.config.ha.ReplicatedPolicyConfiguration;
import org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl;
import org.apache.activemq.artemis.core.server.impl.SharedNothingLiveActivation;
+import org.apache.activemq.artemis.junit.Wait;
import org.apache.activemq.artemis.tests.integration.cluster.util.BackupSyncDelay;
import org.junit.Test;
@@ -96,8 +97,11 @@ public class QuorumFailOverLiveVotesTest extends StaticClusterWithBackupFailover
waitForFailoverTopology(5, 3, 1, 2);
assertTrue(servers[3].waitForActivation(2, TimeUnit.SECONDS));
+ Wait.assertTrue(servers[3]::isStarted);
+ Wait.assertTrue(servers[3]::isActive);
liveActivation.freezeReplication();
- waitForServerToStop(servers[0]);
+ Wait.assertFalse(servers[0]::isStarted);
+ Wait.assertFalse(servers[0]::isActive);
}
@Override