diff options
author | Alex Rudyy <orudyy@apache.org> | 2014-02-19 16:30:23 +0000 |
---|---|---|
committer | Alex Rudyy <orudyy@apache.org> | 2014-02-19 16:30:23 +0000 |
commit | 7744edf70c7c320d193115b278bd16a4c5167702 (patch) | |
tree | 774c6105b9f8b3df07a64c4dfe45a434ce50291c /qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/HAClusterBlackboxTest.java | |
parent | a1b37fcc9c91b32ec1e4c43df43b5150563d0826 (diff) | |
download | qpid-python-java-broker-bdb-ha.tar.gz |
QPID-5409: Restart the former master environment on MASTER transferjava-broker-bdb-ha
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-bdb-ha@1569814 13f79535-47bb-0310-9956-ffa450edef68
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); |