[jboss-cvs] JBoss Messaging SVN: r6101 - trunk/tests/src/org/jboss/messaging/tests/integration/client.

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

Author: ataylor
Date: 2009-03-17 10:44:18 -0400 (Tue, 17 Mar 2009)
New Revision: 6101

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionTest.java
Log:
fixed session tests

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionTest.java	2009-03-17 04:08:18 UTC (rev 6100)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionTest.java	2009-03-17 14:44:18 UTC (rev 6101)
@@ -553,34 +553,34 @@
          assertEquals(10, q.getMessageCount());
          ClientConsumer cc = clientSession.createConsumer(queueName);
          clientSession.start();
-         ClientMessage m = cc.receive(5);
+         ClientMessage m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
          clientSession.commit();
@@ -624,34 +624,34 @@
          assertEquals(10, q.getMessageCount());
          ClientConsumer cc = clientSession.createConsumer(queueName);
          clientSession.start();
-         ClientMessage m = cc.receive(5);
+         ClientMessage m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
-         m = cc.receive(5);
+         m = cc.receive(5000);
          assertNotNull(m);
          m.acknowledge();
          clientSession.rollback();