[jboss-cvs] JBossAS SVN: r71656 - in branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/resendmdb: test and 1 other directory.

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

Author: clebert.suconic at jboss.com
Date: 2008-04-02 19:27:00 -0400 (Wed, 02 Apr 2008)
New Revision: 71656

Modified:
   branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/resendmdb/beans/ResendMDB.java
   branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/resendmdb/test/ResendMDBUnitTestCase.java
Log:
Changes on test to avoid occasional failures

Modified: branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/resendmdb/beans/ResendMDB.java
===================================================================
--- branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/resendmdb/beans/ResendMDB.java	2008-04-02 23:14:22 UTC (rev 71655)
+++ branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/resendmdb/beans/ResendMDB.java	2008-04-02 23:27:00 UTC (rev 71656)
@@ -64,6 +64,7 @@
             Session s = c.createSession(false, Session.AUTO_ACKNOWLEDGE);
             MessageProducer p = s.createProducer(queue);
             p.send(message);
+            Thread.sleep(1000); // Non Persistent Messages are asynchronous
          }
          finally
          {

Modified: branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/resendmdb/test/ResendMDBUnitTestCase.java
===================================================================
--- branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/resendmdb/test/ResendMDBUnitTestCase.java	2008-04-02 23:14:22 UTC (rev 71655)
+++ branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/resendmdb/test/ResendMDBUnitTestCase.java	2008-04-02 23:27:00 UTC (rev 71656)
@@ -69,16 +69,16 @@
          
          // Clear all the queues
          MessageConsumer r = s.createConsumer(a);
-         while (r.receiveNoWait() != null);
+         while (r.receive(500) != null);
          r.close();
          r = s.createConsumer(b);
-         while (r.receiveNoWait() != null);
+         while (r.receive(500) != null);
          r.close();
          r = s.createConsumer(c);
-         while (r.receiveNoWait() != null);
+         while (r.receive(500) != null);
          r.close();
          r = s.createConsumer(d);
-         while (r.receiveNoWait() != null);
+         while (r.receive(500) != null);
          r.close();
          
          MessageProducer p = s.createProducer(a);