activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r378730 - /incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/MultiBrokersMultiClientsTest.java
Date Sat, 18 Feb 2006 15:25:29 GMT
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++) {



Mime
View raw message