[jboss-cvs] JBoss Messaging SVN: r2730 - branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2007-05-26 16:57:39 -0400 (Sat, 26 May 2007)
New Revision: 2730

Modified:
   branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/TransactedSessionTest.java
Log:
Increased timeout on receive() to avoid race condition


Modified: branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/TransactedSessionTest.java
===================================================================
--- branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/TransactedSessionTest.java	2007-05-25 07:24:27 UTC (rev 2729)
+++ branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/TransactedSessionTest.java	2007-05-26 20:57:39 UTC (rev 2730)
@@ -352,7 +352,7 @@
          int count = 0;
          while (true)
          {
-            Message m = consumer.receive(500);
+            Message m = consumer.receive(2000);
             if (m == null) break;
             count++;
          }
@@ -408,7 +408,7 @@
          int count = 0;
          while (true)
          {
-            Message m = consumer.receive(500);
+            Message m = consumer.receive(2000);
             if (m == null) break;
             count++;
          }
@@ -732,7 +732,7 @@
          int count = 0;
          while (true)
          {
-            Message m = consumer.receive(500);
+            Message m = consumer.receive(2000);
             if (m == null) break;
             count++;
          }
@@ -825,7 +825,7 @@
          int count = 0;
          while (true)
          {
-            Message m = consumer.receive(500);
+            Message m = consumer.receive(2000);
             if (m == null) break;
             count++;
          }
@@ -846,7 +846,7 @@
          count = 0;
          while (true)
          {
-            Message m = consumer.receive(500);
+            Message m = consumer.receive(2000);
             if (m == null) break;
             count++;
          }
@@ -904,7 +904,7 @@
          int count = 0;
          while (true)
          {
-            Message m = consumer.receive(500);
+            Message m = consumer.receive(2000);
             if (m == null) break;
             count++;
          }
@@ -1057,7 +1057,7 @@
          Session producerSess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
          MessageProducer producer = producerSess.createProducer(queue);
    
-         Session consumerSess = conn.createSession(true, Session.CLIENT_ACKNOWLEDGE);
+         Session consumerSess = conn.createSession(true, Session.AUTO_ACKNOWLEDGE);
          MessageConsumer consumer = consumerSess.createConsumer(queue);
          conn.start();
    
@@ -1075,7 +1075,7 @@
          int count = 0;
          while (true)
          {
-            Message m = consumer.receive(500);
+            Message m = consumer.receive(2000);
             if (m == null) break;
             count++;
          }
@@ -1091,14 +1091,14 @@
    
          conn = cf.createConnection();
    
-         consumerSess = conn.createSession(true, Session.CLIENT_ACKNOWLEDGE);
+         consumerSess = conn.createSession(true, Session.AUTO_ACKNOWLEDGE);
          consumer = consumerSess.createConsumer(queue);
          conn.start();
    
          count = 0;
          while (true)
          {
-            Message m = consumer.receive(500);
+            Message m = consumer.receive(2000);
             if (m == null) break;
             count++;
          }
@@ -1158,7 +1158,7 @@
          int count = 0;
          while (true)
          {
-            Message m = consumer.receive(500);
+            Message m = consumer.receive(2000);
             if (m == null) break;
             count++;
          }