[hornetq-commits] JBoss hornetq SVN: r10080 - trunk/tests/src/org/hornetq/tests/integration/client.
Author: clebert.suconic(a)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);
}