[jboss-cvs] JBoss Messaging SVN: r6626 - trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-04-29 18:08:14 -0400 (Wed, 29 Apr 2009)
New Revision: 6626

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/PagingFailoverTest.java
Log:
Increasing the timeout on receive

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/PagingFailoverTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/PagingFailoverTest.java	2009-04-29 21:18:47 UTC (rev 6625)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/PagingFailoverTest.java	2009-04-29 22:08:14 UTC (rev 6626)
@@ -26,6 +26,7 @@
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.atomic.AtomicInteger;
 
+import org.jboss.beans.info.plugins.SetterAndFieldPropertyInfo;
 import org.jboss.messaging.core.client.ClientConsumer;
 import org.jboss.messaging.core.client.ClientMessage;
 import org.jboss.messaging.core.client.ClientProducer;
@@ -55,6 +56,8 @@
 
    // Constants -----------------------------------------------------
 
+   final int RECEIVE_TIMEOUT = 25000;
+
    // Attributes ----------------------------------------------------
 
    // Static --------------------------------------------------------
@@ -177,7 +180,7 @@
                conn.fail(new MessagingException(MessagingException.NOT_CONNECTED));
             }
 
-            ClientMessage message = consumer.receive(10000);
+            ClientMessage message = consumer.receive(RECEIVE_TIMEOUT);
 
 
             assertNotNull(message);
@@ -267,8 +270,6 @@
       {
          final AtomicInteger numberOfMessages = new AtomicInteger(0);
 
-         final int RECEIVE_TIMEOUT = 10000;
-
          final ClientSessionFactory factory;
          final PagingStore store;