[hornetq-commits] JBoss hornetq SVN: r8065 - trunk/tests/src/org/hornetq/tests/integration/management.

[do-not-reply at jboss.org]

Author: timfox
Date: 2009-10-08 05:00:29 -0400 (Thu, 08 Oct 2009)
New Revision: 8065

Modified:
   trunk/tests/src/org/hornetq/tests/integration/management/ClusterConnectionControl2Test.java
Log:
fixed timing issue in test

Modified: trunk/tests/src/org/hornetq/tests/integration/management/ClusterConnectionControl2Test.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/ClusterConnectionControl2Test.java	2009-10-07 21:01:20 UTC (rev 8064)
+++ trunk/tests/src/org/hornetq/tests/integration/management/ClusterConnectionControl2Test.java	2009-10-08 09:00:29 UTC (rev 8065)
@@ -84,11 +84,24 @@
       assertEquals(0, nodes.size());
       
       server_1.start();
-      Thread.sleep(3000);
-
-      nodes = clusterConnectionControl_0.getNodes();
-      System.out.println(nodes);
+      long start = System.currentTimeMillis();
+      
+      while (true)
+      {
+         nodes = clusterConnectionControl_0.getNodes();
+         
+         if (nodes.size() != 1 && System.currentTimeMillis() - start < 30000)
+         {
+            Thread.sleep(100);
+         }
+         else
+         {
+            break;
+         }
+      }
+            
       assertEquals(1, nodes.size());
+      
       String remoteAddress = nodes.values().iterator().next();
       assertTrue(remoteAddress.endsWith(":" + port_1));
    }