Author: rajdavies
Date: Sat Feb 18 07:25:28 2006
New Revision: 378730
URL: http://svn.apache.org/viewcvs?rev=378730&view=rev
Log:
added a sleep after consumers are added and before sending messages
to ensure subscriptions are propagated
Modified:
incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/MultiBrokersMultiClientsTest.java
Modified:
incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/MultiBrokersMultiClientsTest.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/MultiBrokersMultiClientsTest.java?rev=378730&r1=378729&r2=378730&view=diff
==============================================================================
---
incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/MultiBrokersMultiClientsTest.java
(original)
+++
incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/MultiBrokersMultiClientsTest.java
Sat Feb 18 07:25:28 2006
@@ -29,7 +29,7 @@
* @version $Revision: 1.1.1.1 $
*/
public class MultiBrokersMultiClientsTest extends
JmsMultipleBrokersTestSupport {
- public static final int BROKER_COUNT = 5; // number of brokers to
network
+ public static final int BROKER_COUNT = 2; // number of brokers to
network
public static final int CONSUMER_COUNT = 3; // consumers per broker
public static final int PRODUCER_COUNT = 3; // producers per broker
public static final int MESSAGE_COUNT = 10; // messages per producer
@@ -50,6 +50,8 @@
consumerMap.put("Consumer:" + i + ":" + j,
createConsumer("Broker" + i, dest));
}
}
+ //wait for consumers to get propagated
+ Thread.sleep(2000);
// Send messages
for (int i=1; i<=BROKER_COUNT; i++) {
@@ -82,6 +84,7 @@
consumerMap.put("Consumer:" + i + ":" + j,
createConsumer("Broker" + i, dest));
}
}
+ Thread.sleep(2000);
// Send messages
for (int i=1; i<=BROKER_COUNT; i++) {
