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

do-not-reply at jboss.org do-not-reply at jboss.org
Thu Aug 25 23:16:32 EDT 2011


Author: clebert.suconic at jboss.com
Date: 2011-08-25 23:16:31 -0400 (Thu, 25 Aug 2011)
New Revision: 11228

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
Log:
tweak

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:08:55 UTC (rev 11227)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2011-08-26 03:16:31 UTC (rev 11228)
@@ -87,6 +87,8 @@
                                        TransportConstants.DEFAULT_PORT + 9, };
 
    private static final long WAIT_TIMEOUT = 10000;
+   
+   private static final long TIMEOUT_START_SERVER = 1000;
 
    @Override
    protected void setUp() throws Exception
@@ -2021,9 +2023,9 @@
       for (int node : nodes)
       {
          log.info("#test start node " + node);
-         if (System.currentTimeMillis() - timeStarts[node] < 100)
+         if (System.currentTimeMillis() - timeStarts[node] < TIMEOUT_START_SERVER)
          {
-            Thread.sleep(100);
+            Thread.sleep(TIMEOUT_START_SERVER);
          }
          timeStarts[node] = System.currentTimeMillis();
          
@@ -2065,10 +2067,10 @@
          {
             try
             {
-               if (System.currentTimeMillis() - timeStarts[node] < 100)
+               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(100);
+                  Thread.sleep(TIMEOUT_START_SERVER);
                }
                timeStarts[node] = System.currentTimeMillis();
                



More information about the hornetq-commits mailing list