[hornetq-commits] JBoss hornetq SVN: r10080 - trunk/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-12-27 19:44:28 -0500 (Mon, 27 Dec 2010)
New Revision: 10080

Modified:
   trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java
Log:
avoiding test hanging

Modified: trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java	2010-12-28 00:10:31 UTC (rev 10079)
+++ trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java	2010-12-28 00:44:28 UTC (rev 10080)
@@ -12,16 +12,25 @@
  */
 package org.hornetq.tests.integration.client;
 
+import java.io.ByteArrayOutputStream;
+import java.io.PrintStream;
 import java.util.ArrayList;
 import java.util.Iterator;
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 import junit.framework.Assert;
 
 import org.hornetq.api.core.SimpleString;
-import org.hornetq.api.core.client.*;
+import org.hornetq.api.core.client.ClientConsumer;
+import org.hornetq.api.core.client.ClientMessage;
+import org.hornetq.api.core.client.ClientProducer;
+import org.hornetq.api.core.client.ClientSession;
+import org.hornetq.api.core.client.ClientSessionFactory;
+import org.hornetq.api.core.client.MessageHandler;
+import org.hornetq.api.core.client.ServerLocator;
 import org.hornetq.core.client.impl.ClientProducerCreditManagerImpl;
 import org.hornetq.core.client.impl.ClientProducerCredits;
 import org.hornetq.core.client.impl.ClientProducerInternal;
@@ -325,7 +334,7 @@
 
       for (int i = 0; i < numConsumers; i++)
       {
-         handlers[i].latch.await();
+         assertTrue(handlers[i].latch.await(5, TimeUnit.MINUTES));
 
          Assert.assertNull(handlers[i].exception);
       }