svn commit: r643460 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq: JmsTempDestinationTest.java bugs/DurableConsumerTest.java

[chirino]

Author: chirino
Date: Tue Apr  1 09:01:20 2008
New Revision: 643460

URL: http://svn.apache.org/viewvc?rev=643460&view=rev
Log:
Adding a little more delay so it works with slower machines.

Modified:
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java?rev=643460&r1=643459&r2=643460&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java
 Tue Apr  1 09:01:20 2008
@@ -218,7 +218,7 @@
         // Closing the connection should destroy the temp queue that was
         // created.
         tempConnection.close();
-        Thread.sleep(2000); // Wait a little bit to let the delete take effect.
+        Thread.sleep(5000); // Wait a little bit to let the delete take effect.
 
         // This message delivery NOT should work since the temp connection is
         // now closed.
@@ -256,7 +256,7 @@
 
         // deleting the Queue will cause sends to fail
         queue.delete();
-        Thread.sleep(1000); // Wait a little bit to let the delete take effect.
+        Thread.sleep(5000); // Wait a little bit to let the delete take effect.
 
         // This message delivery NOT should work since the temp connection is
         // now closed.

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java?rev=643460&r1=643459&r2=643460&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
 Tue Apr  1 09:01:20 2008
@@ -91,8 +91,8 @@
         consumer = consumerSession.createDurableSubscriber(topic, 
CONSUMER_NAME);
         consumerConnection.start();
         for (int i =0; i < COUNT;i++) {
-            Message msg =  consumer.receive(5000);
-            assertNotNull(msg);
+            Message msg =  consumer.receive(5000);            
+            assertNotNull("Missing message: "+i, msg);
             if (i != 0 && i%1000==0) {
                 LOG.info("Received msg " + i);
             }