From bcacddfaad7b1a44bc7654e4f390f096c04c0b08 Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Tue, 1 Apr 2008 16:01:20 +0000 Subject: [PATCH] Adding a little more delay so it works with slower machines. git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643460 13f79535-47bb-0310-9956-ffa450edef68 --- .../test/java/org/apache/activemq/JmsTempDestinationTest.java | 4 ++-- .../java/org/apache/activemq/bugs/DurableConsumerTest.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java b/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java index c66cd13b7d..4d1b1cd59a 100755 --- a/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java @@ -218,7 +218,7 @@ public class JmsTempDestinationTest extends TestCase { // 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 @@ public class JmsTempDestinationTest extends TestCase { // 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. diff --git a/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java b/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java index 370cbb184d..2669c5e66a 100755 --- a/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java @@ -91,8 +91,8 @@ public class DurableConsumerTest extends TestCase { 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); }