Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-22 10:16:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA Fixing intermittent failure on QuorumFailOverLiveVotesTest

Browse Source
This commit is contained in:
Clebert Suconic 2019-08-27 11:28:01 -04:00
parent b52dec085a
commit 5d9395ddb9
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -53,7 +53,6 @@ public class QuorumFailOverLiveVotesTest extends StaticClusterWithBackupFailover
}
@Test
public void testQuorumVotingLiveNotDead() throws Exception {
int[] liveServerIDs = new int[]{0, 1, 2};
@ -70,6 +69,10 @@ public class QuorumFailOverLiveVotesTest extends StaticClusterWithBackupFailover
waitForFailoverTopology(4, 0, 1, 2);
waitForFailoverTopology(5, 0, 1, 2);
Wait.assertTrue(servers[0]::isReplicaSync);
Wait.assertTrue(servers[1]::isReplicaSync);
Wait.assertTrue(servers[2]::isReplicaSync);
for (int i : liveServerIDs) {
setupSessionFactory(i, i + 3, isNetty(), false);
createQueue(i, QUEUES_TESTADDRESS, QUEUE_NAME, null, true);
@ -91,7 +94,6 @@ public class QuorumFailOverLiveVotesTest extends StaticClusterWithBackupFailover
assertFalse("no shared storage", servers[3].getHAPolicy().isSharedStore());
SharedNothingLiveActivation liveActivation = (SharedNothingLiveActivation) servers[0].getActivation();
// ;
servers[0].getRemotingService().freeze(null, null);
waitForFailoverTopology(4, 3, 1, 2);
waitForFailoverTopology(5, 3, 1, 2);
@ -99,6 +101,7 @@ public class QuorumFailOverLiveVotesTest extends StaticClusterWithBackupFailover
assertTrue(servers[3].waitForActivation(2, TimeUnit.SECONDS));
Wait.assertTrue(servers[3]::isStarted);
Wait.assertTrue(servers[3]::isActive);
Wait.assertTrue(servers[0]::isReplicaSync);
liveActivation.freezeReplication();
Wait.assertFalse(servers[0]::isStarted);
Wait.assertFalse(servers[0]::isActive);