[jboss-cvs] JBoss Messaging SVN: r2056 - trunk/tests/src/org/jboss/test/messaging/jms/message.

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

Author: timfox
Date: 2007-01-25 12:33:57 -0500 (Thu, 25 Jan 2007)
New Revision: 2056

Modified:
   trunk/tests/src/org/jboss/test/messaging/jms/message/JMSExpirationHeaderTest.java
Log:
Fixed timing issue with test



Modified: trunk/tests/src/org/jboss/test/messaging/jms/message/JMSExpirationHeaderTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/message/JMSExpirationHeaderTest.java	2007-01-25 16:22:45 UTC (rev 2055)
+++ trunk/tests/src/org/jboss/test/messaging/jms/message/JMSExpirationHeaderTest.java	2007-01-25 17:33:57 UTC (rev 2056)
@@ -88,6 +88,10 @@
    {
       Message m = queueProducerSession.createMessage();
       queueProducer.send(m, DeliveryMode.NON_PERSISTENT, 4, 5000);
+      
+      //Delivery is asynch - need to give enough time to get to the consumer
+      Thread.sleep(2000);
+      
       Message result = queueConsumer.receive(10);
       assertEquals(m.getJMSMessageID(), result.getJMSMessageID());
    }
@@ -96,7 +100,10 @@
    {
       Message m = queueProducerSession.createMessage();
       queueProducer.send(m, DeliveryMode.NON_PERSISTENT, 4, 1000);
+      
+      // Delivery is asynch - need to give enough time to get to the consumer
       Thread.sleep(2000);
+      
       assertNull(queueConsumer.receive(100));
    }
 
@@ -104,7 +111,10 @@
    {
       Message m = queueProducerSession.createMessage();
       queueProducer.send(m, DeliveryMode.NON_PERSISTENT, 4, 1000);
+      
+      // Delivery is asynch - need to give enough time to get to the consumer
       Thread.sleep(2000);
+      
       assertNull(queueConsumer.receiveNoWait());
    }
 
@@ -112,6 +122,8 @@
    {
       Message m = queueProducerSession.createMessage();
       queueProducer.send(m, DeliveryMode.NON_PERSISTENT, 4, 1000);
+      
+      // Delivery is asynch - need to give enough time to get to the consumer
       Thread.sleep(2000);
 
       // start the receiver thread
@@ -307,6 +319,7 @@
       
       queueProducer.send(m, DeliveryMode.NON_PERSISTENT, 4, 1000);
       
+      //Delivery is asynch - need to give enough time to get to the consumer
       Thread.sleep(2000);
       
       assertNull(queueConsumer.receive(100));
@@ -327,9 +340,6 @@
    }
 
 
-
-
-
    // Package protected ---------------------------------------------
    
    // Protected -----------------------------------------------------