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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-11-29 10:31:22 -0500 (Tue, 29 Nov 2011)
New Revision: 11787

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/OneWayChainClusterTest.java
Log:
fix on test

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/OneWayChainClusterTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/OneWayChainClusterTest.java	2011-11-29 14:57:55 UTC (rev 11786)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/OneWayChainClusterTest.java	2011-11-29 15:31:22 UTC (rev 11787)
@@ -360,7 +360,16 @@
       assertEquals(1, connectionSet.size());
       ClusterConnectionImpl ccon = (ClusterConnectionImpl) connectionSet.iterator().next();
 
-      Map<String, MessageFlowRecord> records =  ccon.getRecords();
+      long timeout = System.currentTimeMillis() + 5000;
+      Map<String, MessageFlowRecord> records = null;
+      while (timeout > System.currentTimeMillis())
+      {
+         records =  ccon.getRecords();
+         if (records != null && records.size() == 1)
+         {
+            break;
+         }
+      }
       assertNotNull(records);
       assertEquals(records.size(), 1);
       getServer(1).getClusterManager().getClusterConnections();