Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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
This commit is contained in:
Hiram R. Chirino 2008-04-01 16:01:20 +00:00
parent 53756f3c19
commit bcacddfaad
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java
View File

@ -218,7 +218,7 @@ public class JmsTempDestinationTest extends TestCase {
// Closing the connection should destroy the temp queue that was // Closing the connection should destroy the temp queue that was
// created. // created.
tempConnection.close(); 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 // This message delivery NOT should work since the temp connection is
// now closed. // now closed.
@ -256,7 +256,7 @@ public class JmsTempDestinationTest extends TestCase {
// deleting the Queue will cause sends to fail // deleting the Queue will cause sends to fail
queue.delete(); 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 // This message delivery NOT should work since the temp connection is
// now closed. // now closed.

4
activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
View File

@ -91,8 +91,8 @@ public class DurableConsumerTest extends TestCase {
consumer = consumerSession.createDurableSubscriber(topic, CONSUMER_NAME); consumer = consumerSession.createDurableSubscriber(topic, CONSUMER_NAME);
consumerConnection.start(); consumerConnection.start();
for (int i =0; i < COUNT;i++) { for (int i =0; i < COUNT;i++) {
Message msg = consumer.receive(5000); Message msg = consumer.receive(5000);
assertNotNull(msg); assertNotNull("Missing message: "+i, msg);
if (i != 0 && i%1000==0) { if (i != 0 && i%1000==0) {
LOG.info("Received msg " + i); LOG.info("Received msg " + i);
} }