Author: jmesnil Date: 2009-11-30 04:43:48 -0500 (Mon, 30 Nov 2009) New Revision: 8461 Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java Log: speed up tests * used consumer.receiveImmediate() instead of consumer.receive(1000) to speed up tests 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 09:38:20 UTC (rev 8460) +++ trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-11-30 09:43:48 UTC (rev 8461) @@ -804,8 +804,8 @@ ClientMessage message; do { - message = holder.consumer.receive(1000); - + message = holder.consumer.receiveImmediate(); + if (message != null) { int count = (Integer)message.getObjectProperty(COUNT_PROP);