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

ARTEMIS-2338 Adding Wait clauses on QuorumFailOverLiveVotesTest

This commit is contained in:
Clebert Suconic 2019-06-21 09:21:52 -04:00
parent f54c299ca5
commit d1edb8d6e2
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/QuorumFailOverLiveVotesTest.java
View File

@ -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