svn commit: r360197 - in /incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker: QueueSubscriptionTest.java TopicSubscriptionTest.java

[chirino]

Author: chirino
Date: Fri Dec 30 15:33:46 2005
New Revision: 360197

URL: http://svn.apache.org/viewcvs?rev=360197&view=rev
Log:
not sure why.. but these guys are passing for me now.

Modified:
    
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/QueueSubscriptionTest.java
    
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/TopicSubscriptionTest.java

Modified: 
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/QueueSubscriptionTest.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/QueueSubscriptionTest.java?rev=360197&r1=360196&r2=360197&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/QueueSubscriptionTest.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/QueueSubscriptionTest.java
 Fri Dec 30 15:33:46 2005
@@ -136,9 +136,6 @@
 
         startConsumers(consumerFactory, dest);
 
-        // Wait for consumers to setup
-//        Thread.sleep(1000);
-
         startProducers(dest, messageCount);
 
         // Wait for messages to be received. Make it proportional to the 
messages delivered.

Modified: 
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/TopicSubscriptionTest.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/TopicSubscriptionTest.java?rev=360197&r1=360196&r2=360197&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/TopicSubscriptionTest.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/TopicSubscriptionTest.java
 Fri Dec 30 15:33:46 2005
@@ -24,10 +24,22 @@
         topic = true;
     }
 
+    public void testManyProducersManyConsumers() throws Exception {
+        consumerCount = 20;
+        producerCount = 20;
+        messageCount  = 500;
+        messageSize   = 1; 
+        prefetchCount = 10;
+
+        doMultipleClientsTest();
+
+        assertTotalMessagesReceived(messageCount * producerCount * 
consumerCount);
+    }
+
     public void testOneProducerTwoConsumersLargeMessagesOnePrefetch() throws 
Exception {
         consumerCount = 2;
         producerCount = 1;
-        messageCount  = 100;
+        messageCount  = 10;
         messageSize   = 1024 * 1024 * 1; // 1 MB
         prefetchCount = 1;
 
@@ -101,18 +113,6 @@
         consumerCount = 1;
         producerCount = 20;
         messageCount  = 100;
-        messageSize   = 1; // 1 byte
-        prefetchCount = 10;
-
-        doMultipleClientsTest();
-
-        assertTotalMessagesReceived(messageCount * producerCount * 
consumerCount);
-    }
-
-    public void testManyProducersManyConsumers() throws Exception {
-        consumerCount = 20;
-        producerCount = 20;
-        messageCount  = 20;
         messageSize   = 1; // 1 byte
         prefetchCount = 10;