You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2008/04/04 15:23:44 UTC
svn commit: r644706 - in /activemq/trunk/activemq-camel-loadtest/src/test: java/org/apache/activemq/soaktest/localBroker/ resources/org/apache/activemq/soaktest/localBroker/

Author: jstrachan
Date: Fri Apr  4 06:23:30 2008
New Revision: 644706

URL: http://svn.apache.org/viewvc?rev=644706&view=rev
Log:
added another load test which uses concurrent consumers

Added:
    activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest.java
      - copied, changed from r643847, activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/localBroker/LocalBrokerLoadTest.java
    activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest-context.xml
      - copied, changed from r643939, activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/localBroker/LocalBrokerLoadTest-context.xml

Copied: activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest.java (from r643847, activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/localBroker/LocalBrokerLoadTest.java)
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest.java?p2=activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest.java&p1=activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/localBroker/LocalBrokerLoadTest.java&r1=643847&r2=644706&rev=644706&view=diff
==============================================================================
--- activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/localBroker/LocalBrokerLoadTest.java (original)
+++ activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest.java Fri Apr  4 06:23:30 2008
@@ -29,7 +29,7 @@
  * @version $Revision: 1.1 $
  */
 @ContextConfiguration
-public class LocalBrokerLoadTest extends AbstractJUnit38SpringContextTests {
+public class LocalBrokerParallelProducerLoadTest extends AbstractJUnit38SpringContextTests {
     @Autowired
     protected CamelContext camelContext;
 

Copied: activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest-context.xml (from r643939, activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/localBroker/LocalBrokerLoadTest-context.xml)
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest-context.xml?p2=activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest-context.xml&p1=activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/localBroker/LocalBrokerLoadTest-context.xml&r1=643939&r2=644706&rev=644706&view=diff
==============================================================================
--- activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/localBroker/LocalBrokerLoadTest-context.xml (original)
+++ activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/localBroker/LocalBrokerParallelProducerLoadTest-context.xml Fri Apr  4 06:23:30 2008
@@ -27,39 +27,30 @@
   <camelContext xmlns="http://activemq.apache.org/camel/schema/spring">
 
     <route>
-      <from uri="dataset:myDataSet"/>
+      <from uri="dataset:myDataSet?preloadSize=50000"/>
 
-      <!-- lets use concurrency -->
       <to uri="activemq:foo.example.A"/>
+
+      <!-- lets use concurrency -->
 <!--
-      <thread coreSize="1" daemon="true" keepAliveTime="1000" maxSize="1" priority="1" stackSize="1000">
+      <thread coreSize="10" maxSize="20">
       </thread>
 -->
     </route>
 
     <route>
-      <from uri="activemq:foo.example.A"/>
-      <to uri="mock:results?expectedCount=10000&amp;reportGroup=100&amp;resultWaitTime=400000"/>
-      <!--
-      <resequencer>
-        <simple>header.camelDataSetIndex</simple>
-        <to uri="dataset:myDataSet"/>
-      </resequencer>
--->
+      <from uri="activemq:foo.example.A?concurrentConsumers=5"/>
+      <to uri="mock:results?expectedMessageCount=100000&amp;reportGroup=5000&amp;resultWaitTime=400000"/>
     </route>
 
   </camelContext>
 
   <bean id="myDataSet" class="org.apache.camel.component.dataset.SimpleDataSet">
-    <property name="size" value="10000"/>
-    <property name="reportCount" value="100"/>
+    <property name="size" value="100000"/>
+    <property name="reportCount" value="5000"/>
   </bean>
 
   <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
-<!--
-    <property name="useSingleConnection" value="true"/>
-    <property name="usePooledConnection" value="false"/>
--->
   </bean>
 </beans>
 <!-- END SNIPPET: example -->