svn commit: r735024 - /qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java

[rhs]

Author: rhs
Date: Fri Jan 16 06:17:42 2009
New Revision: 735024

URL: http://svn.apache.org/viewvc?rev=735024&view=rev
Log:
added a timeout to BytesMessageTest

Modified:
    
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java

Modified: 
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java
URL: 
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java?rev=735024&r1=735023&r2=735024&view=diff
==============================================================================
--- 
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java
 (original)
+++ 
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/BytesMessageTest.java
 Fri Jan 16 06:17:42 2009
@@ -29,6 +29,7 @@
 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 @@
     {
         synchronized (received)
         {
-            while (received.size() < count)
+            Waiter w = new Waiter(received, 30000);
+            while (received.size() < count && w.hasTime())
             {
-                received.wait();
+                w.await();
             }
         }
     }