Author: clebert.suconic(a)jboss.com Date: 2011-08-26 02:41:31 -0400 (Fri, 26 Aug 2011) New Revision: 11230 Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java Log: I'm having issues with versioning of Topic Members. Until I implement a better algorithm I will keep a sleep before each server is started on the testsuite Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java =================================================================== --- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2011-08-26 03:53:29 UTC (rev 11229) +++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2011-08-26 06:41:31 UTC (rev 11230) @@ -88,7 +88,7 @@ private static final long WAIT_TIMEOUT = 10000; - private static final long TIMEOUT_START_SERVER = 1000; + private static final long TIMEOUT_START_SERVER = 500; @Override protected void setUp() throws Exception @@ -2023,10 +2023,11 @@ for (int node : nodes) { log.info("#test start node " + node); - if (System.currentTimeMillis() - timeStarts[node] < TIMEOUT_START_SERVER) - { - Thread.sleep(TIMEOUT_START_SERVER); - } +// if (System.currentTimeMillis() - timeStarts[node] < TIMEOUT_START_SERVER) +// { +// Thread.sleep(TIMEOUT_START_SERVER); +// } + Thread.sleep(TIMEOUT_START_SERVER); timeStarts[node] = System.currentTimeMillis(); servers[node].setIdentity("server " + node); @@ -2067,11 +2068,14 @@ { try { - if (System.currentTimeMillis() - timeStarts[node] < TIMEOUT_START_SERVER) - { - // We can't stop and start a node too fast (faster than what the Topology could realize about this - Thread.sleep(TIMEOUT_START_SERVER); - } +// if (System.currentTimeMillis() - timeStarts[node] < TIMEOUT_START_SERVER) +// { +// // We can't stop and start a node too fast (faster than what the Topology could realize about this +// Thread.sleep(TIMEOUT_START_SERVER); +// } + + Thread.sleep(TIMEOUT_START_SERVER); + timeStarts[node] = System.currentTimeMillis(); ClusterTestBase.log.info("stopping server " + node);