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

give test some more time for slower machines 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@766639 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2009-04-20 10:18:31 +00:00
parent a259babc34
commit 047030447d
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
activemq-core/src/test/java/org/apache/activemq/usecases/ThreeBrokerQueueNetworkTest.java
View File

@ -317,7 +317,7 @@ public class ThreeBrokerQueueNetworkTest extends JmsMultipleBrokersTestSupport {
MessageConsumer clientA = createConsumer("BrokerA", dest, messagesReceived); MessageConsumer clientA = createConsumer("BrokerA", dest, messagesReceived);
// ensure advisory percolation. // ensure advisory percolation.
Thread.sleep(1000); Thread.sleep(2000);
// Send messages // Send messages
sendMessages("BrokerB", dest, messageCount); sendMessages("BrokerB", dest, messageCount);
@ -342,7 +342,7 @@ public class ThreeBrokerQueueNetworkTest extends JmsMultipleBrokersTestSupport {
MessageConsumer clientA = createConsumer("BrokerA", dest); MessageConsumer clientA = createConsumer("BrokerA", dest);
// ensure advisors have percolated // ensure advisors have percolated
Thread.sleep(500); Thread.sleep(2000);
LOG.info("Consumer on B"); LOG.info("Consumer on B");
int messageCount = 2000; int messageCount = 2000;
@ -352,13 +352,13 @@ public class ThreeBrokerQueueNetworkTest extends JmsMultipleBrokersTestSupport {
MessageConsumer clientB = createConsumer("BrokerB", dest, messagesReceived); MessageConsumer clientB = createConsumer("BrokerB", dest, messagesReceived);
// ensure advisors have percolated // ensure advisors have percolated
Thread.sleep(500); Thread.sleep(2000);
LOG.info("Close consumer on A"); LOG.info("Close consumer on A");
clientA.close(); clientA.close();
// ensure advisors have percolated // ensure advisors have percolated
Thread.sleep(500); Thread.sleep(2000);
LOG.info("Send to B"); LOG.info("Send to B");
sendMessages("BrokerB", dest, messageCount); sendMessages("BrokerB", dest, messageCount);
@ -399,7 +399,7 @@ public class ThreeBrokerQueueNetworkTest extends JmsMultipleBrokersTestSupport {
MessageConsumer clientA = createConsumer("BrokerA", dest); MessageConsumer clientA = createConsumer("BrokerA", dest);
// ensure advisors have percolated // ensure advisors have percolated
Thread.sleep(500); Thread.sleep(2000);
LOG.info("Consumer on B"); LOG.info("Consumer on B");
int messageCount = 2000; int messageCount = 2000;
@ -412,19 +412,19 @@ public class ThreeBrokerQueueNetworkTest extends JmsMultipleBrokersTestSupport {
msgs.setProcessingDelay(10); msgs.setProcessingDelay(10);
// ensure advisors have percolated // ensure advisors have percolated
Thread.sleep(500); Thread.sleep(2000);
LOG.info("Close consumer on A"); LOG.info("Close consumer on A");
clientA.close(); clientA.close();
// ensure advisors have percolated // ensure advisors have percolated
Thread.sleep(500); Thread.sleep(2000);
LOG.info("Send to B"); LOG.info("Send to B");
sendMessages("BrokerB", dest, messageCount); sendMessages("BrokerB", dest, messageCount);
// Let's try to wait for any messages. // Let's try to wait for any messages.
assertTrue(messagesReceived.await(30, TimeUnit.SECONDS)); assertTrue(messagesReceived.await(60, TimeUnit.SECONDS));
assertEquals(messageCount, msgs.getMessageCount()); assertEquals(messageCount, msgs.getMessageCount());
} }