Author: jmesnil Date: 2009-11-30 05:11:25 -0500 (Mon, 30 Nov 2009) New Revision: 8463 Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java Log: reverted r8461 * messages may need some time to reach some nodes before they can be consumed Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-11-30 10:10:50 UTC (rev 8462) +++ trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-11-30 10:11:25 UTC (rev 8463) @@ -804,7 +804,7 @@ ClientMessage message; do { - message = holder.consumer.receiveImmediate(); + message = holder.consumer.receive(500); if (message != null) {