Author: clebert.suconic(a)jboss.com Date: 2011-08-31 18:42:32 -0400 (Wed, 31 Aug 2011) New Revision: 11265 Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java Log: fixing another intermittent failure Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java =================================================================== --- branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java 2011-08-31 20:11:58 UTC (rev 11264) +++ branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java 2011-08-31 22:42:32 UTC (rev 11265) @@ -54,6 +54,11 @@ setupCluster(); startServers(0, 1, 2, 3, 4); + + for (int i = 0 ; i < 5; i++) + { + waitForTopology(servers[i], 5); + } setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -97,7 +102,12 @@ setupCluster(); startServers(0, 1, 2, 3, 4); - + + for (int i = 0 ; i < 5; i++) + { + waitForTopology(servers[i], 5); + } + setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); setupSessionFactory(2, isNetty());