added a timeout to BytesMessageTest

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@735024 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 2 deletions

diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java
index 9a7fe7c039..7db53ec50c 100644
--- a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java
+++ b/qpid/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();
             }
         }
     }