Author: clebert.suconic(a)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();