Author: orudyy
Date: Tue Sep 16 11:24:38 2014
New Revision: 1625245
URL: http://svn.apache.org/r1625245
Log:
QPID-6104: Fix test ReplicatedEnvironmentFacadeTest.testRemoveNodeFromGroup
Modified:
qpid/trunk/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacadeTest.java
Modified:
qpid/trunk/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacadeTest.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacadeTest.java?rev=1625245&r1=1625244&r2=1625245&view=diff
==============================================================================
---
qpid/trunk/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacadeTest.java
(original)
+++
qpid/trunk/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacadeTest.java
Tue Sep 16 11:24:38 2014
@@ -374,7 +374,10 @@ public class ReplicatedEnvironmentFacade
public void testRemoveNodeFromGroup() throws Exception
{
- ReplicatedEnvironmentFacade environmentFacade = createMaster();
+ TestStateChangeListener stateChangeListener = new
TestStateChangeListener(State.MASTER);
+ ReplicatedEnvironmentFacade environmentFacade =
addNode(TEST_NODE_NAME, TEST_NODE_HOST_PORT, true, stateChangeListener, new
NoopReplicationGroupListener());
+ assertTrue("Environment was not created",
stateChangeListener.awaitForStateChange(LISTENER_TIMEOUT, TimeUnit.SECONDS));
+
String node2Name = TEST_NODE_NAME + "_2";
String node2NodeHostPort = "localhost:" +
getNextAvailable(TEST_NODE_PORT + 1);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
