[hornetq-commits] JBoss hornetq SVN: r8461 - trunk/tests/src/org/hornetq/tests/integration/cluster/distribution.

[do-not-reply at jboss.org]

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);