[hornetq-commits] JBoss hornetq SVN: r11239 - branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-08-29 17:52:17 -0400 (Mon, 29 Aug 2011)
New Revision: 11239

Modified:
   branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/OneWayChainClusterTest.java
Log:
Adding back a sleep that was needed

Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/OneWayChainClusterTest.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/OneWayChainClusterTest.java	2011-08-29 20:30:46 UTC (rev 11238)
+++ branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/OneWayChainClusterTest.java	2011-08-29 21:52:17 UTC (rev 11239)
@@ -316,6 +316,9 @@
 
       stopServers(2);
 
+      waitForTopology(servers[1], 4);
+
+      Thread.sleep(1000);
       log.info("============================================ after stop");
       log.info(clusterDescription(servers[0]));
       log.info(clusterDescription(servers[1]));
@@ -323,7 +326,12 @@
       log.info(clusterDescription(servers[4]));
 
       startServers(2);
+      
 
+      Thread.sleep(1000);
+
+      waitForTopology(servers[1], 5);
+
       log.info("============================================ after start");
       log.info(clusterDescription(servers[0]));
       log.info(clusterDescription(servers[1]));