You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ai...@apache.org on 2008/09/19 11:53:33 UTC
svn commit: r697021 - /incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java

Author: aidan
Date: Fri Sep 19 02:53:33 2008
New Revision: 697021

URL: http://svn.apache.org/viewvc?rev=697021&view=rev
Log:
QPID-1286: make timeout a constant

Modified:
    incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java

Modified: incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java?rev=697021&r1=697020&r2=697021&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java (original)
+++ incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java Fri Sep 19 02:53:33 2008
@@ -45,6 +45,9 @@
 /** Test Case provided by client Non-functional Test NF101: heap exhaustion behaviour */
 public class PriorityTest extends TestCase
 {
+    private static final int TIMEOUT = 1500;
+
+
     private static final Logger _logger = Logger.getLogger(PriorityTest.class);
 
 
@@ -190,31 +193,31 @@
         consumer = consumerSession.createConsumer(queue);
         consumerConnection.start();
         
-        Message msg = consumer.receive(500);
+        Message msg = consumer.receive(TIMEOUT);
         assertEquals(1, msg.getIntProperty("msg"));
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(5, msg.getIntProperty("msg"));
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(9, msg.getIntProperty("msg"));
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(12, msg.getIntProperty("msg"));
         
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(2, msg.getIntProperty("msg"));
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(4, msg.getIntProperty("msg"));
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(7, msg.getIntProperty("msg"));
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(11, msg.getIntProperty("msg"));
         
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(3, msg.getIntProperty("msg"));
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(6, msg.getIntProperty("msg"));
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(8, msg.getIntProperty("msg"));
-        msg = consumer.receive(500);
+        msg = consumer.receive(TIMEOUT);
         assertEquals(10, msg.getIntProperty("msg"));
     }