[jboss-cvs] JBossAS SVN: r77273 - trunk/testsuite/src/main/org/jboss/test/timer/test.

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

Author: jesper.pedersen
Date: 2008-08-21 04:19:28 -0400 (Thu, 21 Aug 2008)
New Revision: 77273

Modified:
   trunk/testsuite/src/main/org/jboss/test/timer/test/BasicTimerUnitTestCase.java
Log:
[JBAS-5866] Empty the queue before using it

Modified: trunk/testsuite/src/main/org/jboss/test/timer/test/BasicTimerUnitTestCase.java
===================================================================
--- trunk/testsuite/src/main/org/jboss/test/timer/test/BasicTimerUnitTestCase.java	2008-08-21 07:53:03 UTC (rev 77272)
+++ trunk/testsuite/src/main/org/jboss/test/timer/test/BasicTimerUnitTestCase.java	2008-08-21 08:19:28 UTC (rev 77273)
@@ -352,7 +352,13 @@
          
          session = queConn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
          sender = session.createSender(queueA);
+         receiver = session.createReceiver(queueB);
 
+         while (receiver.receiveNoWait() != null)
+         {
+            // Empty the queue
+         }
+
          TextMessage message = session.createTextMessage();
          message.setText("testMDBTimer");
          message.setIntProperty("UNIQUE_ID", 123456789);
@@ -360,7 +366,6 @@
          sender.send(message);
 
          // Get the initial onMessage ack
-         receiver = session.createReceiver(queueB);
          Message reply = receiver.receive(30000);
          log.info("onMessage reply: " + reply);
          assertTrue("onMessage reply != null", reply != null);
@@ -443,6 +448,13 @@
 
          session = queConn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
          sender = session.createSender(queueA);
+         receiver = session.createReceiver(queueB);
+
+         while (receiver.receiveNoWait() != null)
+         {
+            // Empty the queue
+         }
+
          TextMessage message = session.createTextMessage();
          message.setText("testOnCreateMDBTimer");
          message.setIntProperty("UNIQUE_ID", 123456788);
@@ -450,7 +462,6 @@
          sender.send(message);
 
          // Get the initial onMessage ack
-         receiver = session.createReceiver(queueB);
          Message reply = receiver.receive(15000);
          log.info("onMessage reply: " + reply);
          assertTrue("onMessage reply != null", reply != null);