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

Fix ReplicatedMultipleServerFailoverExtraBackupsTest

This commit is contained in:
jbertram 2015-08-11 14:06:58 -05:00
parent 53fe8ec9f7
commit f6061d0d53
1 changed files with 6 additions and 1 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/ReplicatedMultipleServerFailoverExtraBackupsTest.java
View File

@ -38,10 +38,15 @@ public class ReplicatedMultipleServerFailoverExtraBackupsTest extends Replicated
((ReplicaPolicyConfiguration) backupServers.get(3).getServer().getConfiguration().getHAPolicyConfiguration()).setGroupName(getNodeGroupName() + "-1"); ((ReplicaPolicyConfiguration) backupServers.get(3).getServer().getConfiguration().getHAPolicyConfiguration()).setGroupName(getNodeGroupName() + "-1");
startServers(liveServers); startServers(liveServers);
startServers(backupServers); backupServers.get(0).start();
backupServers.get(1).start();
waitForRemoteBackupSynchronization(backupServers.get(0).getServer()); waitForRemoteBackupSynchronization(backupServers.get(0).getServer());
waitForRemoteBackupSynchronization(backupServers.get(1).getServer()); waitForRemoteBackupSynchronization(backupServers.get(1).getServer());
// wait to start the other 2 backups so the first 2 can sync with the 2 live servers
backupServers.get(2).start();
backupServers.get(3).start();
sendCrashReceive(); sendCrashReceive();
waitForTopology(backupServers.get(0).getServer(), liveServers.size(), 2); waitForTopology(backupServers.get(0).getServer(), liveServers.size(), 2);
sendCrashBackupReceive(); sendCrashBackupReceive();