activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r412467 - in /incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven: ConsumerMojo.java ProducerMojo.java
Date Wed, 07 Jun 2006 17:47:06 GMT
Author: jstrachan
Date: Wed Jun  7 10:47:06 2006
New Revision: 412467

URL: http://svn.apache.org/viewvc?rev=412467&view=rev
Log:
changed the defaults of the performance test mojos to be more normal (folks usually wanna
see results for 1 producer/consumer and on a decent box they wanna see it go for about a minute)
plus some minor refactorings to make the code a bit easier to maintain

Modified:
    incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java
    incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java

Modified: incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java?rev=412467&r1=412466&r2=412467&view=diff
==============================================================================
--- incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java
(original)
+++ incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java
Wed Jun  7 10:47:06 2006
@@ -39,7 +39,7 @@
     private String duration;
 
     /**
-     * @parameter expression="${sampler.interval}" default-value="5000"
+     * @parameter expression="${sampler.interval}" default-value="1000"
      * @required
      */
     private String interval;
@@ -75,7 +75,7 @@
     private String sessAckMode;
 
     /**
-     * @parameter expression="${consumer.destName}" default-value="topic://FOO.BAR.TEST"
+     * @parameter expression="${consumer.destName}" default-value="topic://TEST.PERFORMANCE.FOO.BAR"
      * @required
      */
     private String destName;
@@ -105,7 +105,7 @@
     private String asyncRecv;
 
     /**
-     * @parameter expression="${consumer.recvCount}" default-value="1000"
+     * @parameter expression="${consumer.recvCount}" default-value="1000000"
      * @required
      */
     private String recvCount;
@@ -142,13 +142,13 @@
     private String optimDispatch;
 
     /**
-     * @parameter expression="${factory.prefetchQueue}" default-value="10"
+     * @parameter expression="${factory.prefetchQueue}" default-value="5000"
      * @required
      */
     private String prefetchQueue;
 
     /**
-     * @parameter expression="${factory.prefetchTopic}" default-value="10"
+     * @parameter expression="${factory.prefetchTopic}" default-value="5000"
      * @required
      */
     private String prefetchTopic;
@@ -160,13 +160,13 @@
     private String useRetroactive;
 
     /**
-     * @parameter expression="${sysTest.numClients}" default-value="5"
+     * @parameter expression="${sysTest.numClients}" default-value="1"
      * @required
      */
     private String numClients;
 
     /**
-     * @parameter expression="${sysTest.totalDests}" default-value="5"
+     * @parameter expression="${sysTest.totalDests}" default-value="1"
      * @required
      */
     private String totalDests;
@@ -195,37 +195,37 @@
     }
 
     public String[] createArgument() {
-        String[] options = new String[25];
-
-        options[0] = "sampler.duration=" + duration;     // 1 min
-        options[1] = "sampler.interval=" + interval;      // 5 secs
-        options[2] = "sampler.rampUpTime=" + rampUpTime;   // 10 secs
-        options[3] = "sampler.rampDownTime=" + rampDownTime; // 10 secs
-
-        options[4] = "consumer.spiClass=" + spiClass;
-        options[5] = "consumer.sessTransacted=" + sessTransacted;
-        options[6] = "consumer.sessAckMode=" + sessAckMode;
-        options[7] = "consumer.destName=" + destName;
-        options[8] = "consumer.destCount=" + destCount;
-        options[9] = "consumer.destComposite=" + destComposite;
-
-        options[10] = "consumer.durable=" + durable;
-        options[11] = "consumer.asyncRecv=" + asyncRecv;
-        options[12] = "consumer.recvCount=" + recvCount;     // 1000 messages
-        options[13] = "consumer.recvDuration=" + duration; // use sampler.duration.
-        options[14] = "consumer.recvType=" + recvType;
-
-        options[15] = "factory.brokerUrl=" + brokerUrl;
-        options[16] = "factory.optimAck=" + optimAck;
-        options[17] = "factory.optimDispatch=" + optimDispatch;
-        options[18] = "factory.prefetchQueue=" + prefetchQueue;
-        options[19] = "factory.prefetchTopic=" + prefetchTopic;
-        options[20] = "factory.useRetroactive=" + useRetroactive;
-
-        options[21] = "sysTest.numClients=" + numClients;
-        options[22] = "sysTest.totalDests=" + totalDests;
-        options[23] = "sysTest.destDistro=" + destDistro;
-        options[24] = "sysTest.reportDirectory=" + reportDirectory;
+        String[] options = {
+            "sampler.duration=" + duration, 
+            "sampler.interval=" + interval,    
+            "sampler.rampUpTime=" + rampUpTime,   
+            "sampler.rampDownTime=" + rampDownTime, 
+    
+            "consumer.spiClass=" + spiClass,
+            "consumer.sessTransacted=" + sessTransacted,
+            "consumer.sessAckMode=" + sessAckMode,
+            "consumer.destName=" + destName,
+            "consumer.destCount=" + destCount,
+            "consumer.destComposite=" + destComposite,
+    
+            "consumer.durable=" + durable,
+            "consumer.asyncRecv=" + asyncRecv,
+            "consumer.recvCount=" + recvCount,   
+            "consumer.recvDuration=" + duration, 
+            "consumer.recvType=" + recvType,
+    
+            "factory.brokerUrl=" + brokerUrl,
+            "factory.optimAck=" + optimAck,
+            "factory.optimDispatch=" + optimDispatch,
+            "factory.prefetchQueue=" + prefetchQueue,
+            "factory.prefetchTopic=" + prefetchTopic,
+            "factory.useRetroactive=" + useRetroactive,
+    
+            "sysTest.numClients=" + numClients,
+            "sysTest.totalDests=" + totalDests,
+            "sysTest.destDistro=" + destDistro,
+            "sysTest.reportDirectory=" + reportDirectory
+        };
 
         return options;
     }

Modified: incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java?rev=412467&r1=412466&r2=412467&view=diff
==============================================================================
--- incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java
(original)
+++ incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java
Wed Jun  7 10:47:06 2006
@@ -37,7 +37,7 @@
     private String duration;
 
     /**
-     * @parameter expression="${sampler.interval}" default-value="5000"
+     * @parameter expression="${sampler.interval}" default-value="1000"
      * @required
      */
     private String interval;
@@ -73,7 +73,7 @@
     private String sessAckMode;
 
     /**
-     * @parameter expression="${producer.destName}" default-value="topic://FOO.BAR.TEST"
+     * @parameter expression="${consumer.destName}" default-value="topic://TEST.PERFORMANCE.FOO.BAR"
      * @required
      */
     private String destName;
@@ -97,7 +97,7 @@
     private String messageSize;
 
     /**
-     * @parameter expression="${producer.sendCount}" default-value="1000"
+     * @parameter expression="${producer.sendCount}" default-value="1000000"
      * @required
      */
     private String sendCount;
@@ -128,13 +128,13 @@
     private String asyncSend;
 
     /**
-     * @parameter expression="${sysTest.numClients}" default-value="5"
+     * @parameter expression="${sysTest.numClients}" default-value="1"
      * @required
      */
     private String numClients;
 
     /**
-     * @parameter expression="${sysTest.totalDests}" default-value="5"
+     * @parameter expression="${sysTest.totalDests}" default-value="1"
      * @required
      */
     private String totalDests;
@@ -160,31 +160,32 @@
 
     public String[] createArgument() {
 
-        String[] options = new String[20];
-        options[0] = "sampler.duration=" + duration;     // 1 min
-        options[1] = "sampler.interval=" + interval;      // 5 secs
-        options[2] = "sampler.rampUpTime=" + rampUpTime;   // 10 secs
-        options[3] = "sampler.rampDownTime=" + rampDownTime; // 10 secs
-
-        options[4] = "producer.spiClass=" + spiClass;
-        options[5] = "producer.sessTransacted=" + sessTransacted;
-        options[6] = "producer.sessAckMode=" + sessAckMode;
-        options[7] = "producer.destName=" + destName;
-        options[8] = "producer.destCount=" + destCount;
-        options[9] = "producer.destComposite=" + destComposite;
-
-        options[10] = "producer.messageSize="+messageSize;
-        options[11] = "producer.sendCount="+sendCount;     // 1000 messages
-        options[12] = "producer.sendDuration="+duration; // use sampler.duration.
-        options[13] = "producer.sendType="+sendType;
-
-        options[14] = "factory.brokerUrl="+brokerUrl;
-        options[15] = "factory.asyncSend="+asyncSend;
-
-        options[16] = "sysTest.numClients=" + numClients;
-        options[17] = "sysTest.totalDests=" + totalDests;
-        options[18] = "sysTest.destDistro=" + destDistro;
-        options[19] = "sysTest.reportDirectory=" + reportDirectory;
+        String[] options = {
+            "sampler.duration=" + duration,   
+            "sampler.interval=" + interval,     
+            "sampler.rampUpTime=" + rampUpTime,   
+            "sampler.rampDownTime=" + rampDownTime, 
+    
+            "producer.spiClass=" + spiClass,
+            "producer.sessTransacted=" + sessTransacted,
+            "producer.sessAckMode=" + sessAckMode,
+            "producer.destName=" + destName,
+            "producer.destCount=" + destCount,
+            "producer.destComposite=" + destComposite,
+    
+            "producer.messageSize="+messageSize,
+            "producer.sendCount="+sendCount,    
+            "producer.sendDuration="+duration, 
+            "producer.sendType="+sendType,
+    
+            "factory.brokerUrl="+brokerUrl,
+            "factory.asyncSend="+asyncSend,
+    
+            "sysTest.numClients=" + numClients,
+            "sysTest.totalDests=" + totalDests,
+            "sysTest.destDistro=" + destDistro,
+            "sysTest.reportDirectory=" + reportDirectory 
+        };
 
         return options;
     }



Mime
View raw message