[jboss-cvs] JBossAS SVN: r71654 - branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test.

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

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

Modified:
   branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test/RollBackUnitTestCase.java
Log:
Changes on test to avoid occasional failures

Modified: branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test/RollBackUnitTestCase.java
===================================================================
--- branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test/RollBackUnitTestCase.java	2008-04-02 23:09:22 UTC (rev 71653)
+++ branches/JBPAPP_4_2_0_GA_CP/testsuite/src/main/org/jboss/test/jbossmessaging/test/RollBackUnitTestCase.java	2008-04-02 23:13:19 UTC (rev 71654)
@@ -119,6 +119,8 @@
                {
                   sender.send(message, persistence, 4, 0);
                }
+               
+               Thread.sleep(2000); // NonPersistentMessages are Asynchronous by default on JBM
 
                if (explicit)
                   session.rollback();
@@ -222,6 +224,8 @@
                   sender.send(message, persistence, 4, 0);
                }
 
+               Thread.sleep(2000); // NonPersistentMessages are Asynchronous by default on JBM
+
                session.close();
             }
             catch (Exception e)
@@ -597,12 +601,12 @@
       Queue queue = (Queue) context.lookup(TEST_QUEUE);
 
       QueueReceiver receiver = session.createReceiver(queue);
-      Message message = receiver.receive(50);
+      Message message = receiver.receive(1000);
       int c = 0;
       while (message != null)
       {
          c++;
-         message = receiver.receive(50);
+         message = receiver.receive(1000);
       }
 
       getLog().debug("  Drained " + c + " messages from the queue");
@@ -624,12 +628,12 @@
       Topic topic = (Topic) context.lookup(TEST_TOPIC);
       TopicSubscriber subscriber = session.createSubscriber(topic);
 
-      Message message = subscriber.receive(50);
+      Message message = subscriber.receive(1000);
       int c = 0;
       while (message != null)
       {
          c++;
-         message = subscriber.receive(50);
+         message = subscriber.receive(1000);
       }
 
       getLog().debug("  Drained " + c + " messages from the topic");
@@ -651,12 +655,12 @@
       Topic topic = (Topic) context.lookup(TEST_DURABLE_TOPIC);
       TopicSubscriber subscriber = session.createDurableSubscriber(topic, "test");
 
-      Message message = subscriber.receive(50);
+      Message message = subscriber.receive(1000);
       int c = 0;
       while (message != null)
       {
          c++;
-         message = subscriber.receive(50);
+         message = subscriber.receive(1000);
       }
 
       getLog().debug("  Drained " + c + " messages from the durable topic");
@@ -675,7 +679,7 @@
       Queue queue = (Queue) context.lookup(TEST_QUEUE);
 
       QueueReceiver receiver = session.createReceiver(queue);
-      receiver.receive();
+      assertNotNull(receiver.receive(10000));
       session.close();
       getLog().debug("Got Synch Message");
    }
@@ -691,6 +695,9 @@
       Message message = session.createMessage();
       sender.send(message);
 
+      Thread.sleep(2000); // NonPersistentMessages are Asynchronous by default on JBM
+
+
       session.close();
       getLog().debug("Sent Synch Message");
    }