[hornetq-commits] JBoss hornetq SVN: r9954 - branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/topology.
do-not-reply at jboss.org
do-not-reply at jboss.org
Tue Nov 30 12:42:13 EST 2010
Author: ataylor
Date: 2010-11-30 12:42:12 -0500 (Tue, 30 Nov 2010)
New Revision: 9954
Modified:
branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/topology/TopologyClusterTestBase.java
Log:
added latch for nodes being removed
Modified: branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/topology/TopologyClusterTestBase.java
===================================================================
--- branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/topology/TopologyClusterTestBase.java 2010-11-30 16:27:01 UTC (rev 9953)
+++ branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/topology/TopologyClusterTestBase.java 2010-11-30 17:42:12 UTC (rev 9954)
@@ -414,6 +414,7 @@
final List<String> nodes = new ArrayList<String>();
final CountDownLatch upLatch = new CountDownLatch(5);
+ final CountDownLatch downLatch = new CountDownLatch(5);
locator.addClusterTopologyListener(new ClusterTopologyListener()
{
@@ -434,6 +435,7 @@
if (nodes.contains(nodeID))
{
nodes.remove(nodeID);
+ downLatch.countDown();
}
}
});
@@ -454,6 +456,8 @@
waitForClusterConnections(4, 4);
stopServers(0, 4, 2, 3, 1);
+
+ assertTrue("Was not notified that all servers are Down", upLatch.await(10, SECONDS));
checkContains(new int[] { }, nodeIDs, nodes);
for (int i = 0; i < sfs.length; i++)
More information about the hornetq-commits
mailing list