From 95f4538c80544a5c70c89a07a2bb62f56753e4e5 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Fri, 16 Jan 2009 14:17:42 +0000 Subject: added a timeout to BytesMessageTest git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735024 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'java') diff --git a/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java b/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java index 9a7fe7c039..7db53ec50c 100644 --- a/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java +++ b/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java @@ -29,6 +29,7 @@ import org.apache.qpid.client.AMQQueue; import org.apache.qpid.client.AMQSession; import org.apache.qpid.client.message.JMSBytesMessage; import org.apache.qpid.test.utils.QpidTestCase; +import org.apache.qpid.transport.util.Waiter; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -131,9 +132,10 @@ public class BytesMessageTest extends QpidTestCase implements MessageListener { synchronized (received) { - while (received.size() < count) + Waiter w = new Waiter(received, 30000); + while (received.size() < count && w.hasTime()) { - received.wait(); + w.await(); } } } -- cgit v1.2.1