diff options
Diffstat (limited to 'qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/HAClusterBlackboxTest.java')
-rw-r--r-- | qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/HAClusterBlackboxTest.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/HAClusterBlackboxTest.java b/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/HAClusterBlackboxTest.java index 84b8de7be9..c327c9f33a 100644 --- a/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/HAClusterBlackboxTest.java +++ b/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/HAClusterBlackboxTest.java @@ -143,6 +143,9 @@ public class HAClusterBlackboxTest extends QpidBrokerTestCase assertEquals("Inactive broker has unexpeced role", "MASTER", attributes.get(ReplicationNode.ROLE)); assertProducingConsuming(connection); + + String nodeName = _clusterCreator.getNodeNameForBrokerPort(activeBrokerPort); + _clusterCreator.awaitNodeToAttainRole(activeBrokerPort, nodeName, "REPLICA"); } public void testTransferMasterFromRemoteNode() throws Exception @@ -171,7 +174,10 @@ public class HAClusterBlackboxTest extends QpidBrokerTestCase assertEquals("Inactive broker has unexpeced role", "MASTER", attributes.get(ReplicationNode.ROLE)); assertProducingConsuming(connection); + + _clusterCreator.awaitNodeToAttainRole(activeBrokerPort, nodeName, "REPLICA"); } + public void testQuorumOverride() throws Exception { final Connection connection = getConnection(_brokerFailoverUrl); |