activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From foco...@apache.org
Subject svn commit: r412301 - in /incubator/activemq/trunk: assembly/ tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/
Date Wed, 07 Jun 2006 06:17:14 GMT
Author: foconer
Date: Tue Jun  6 23:17:14 2006
New Revision: 412301

URL: http://svn.apache.org/viewvc?rev=412301&view=rev
Log:
changed prefix consumer and producer to "client". Also, the broker can be started in activemq-perftest
instead in the assembly.

Modified:
    incubator/activemq/trunk/assembly/pom.xml
    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
    incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfReportGenerator.java

Modified: incubator/activemq/trunk/assembly/pom.xml
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/assembly/pom.xml?rev=412301&r1=412300&r2=412301&view=diff
==============================================================================
--- incubator/activemq/trunk/assembly/pom.xml (original)
+++ incubator/activemq/trunk/assembly/pom.xml Tue Jun  6 23:17:14 2006
@@ -296,17 +296,7 @@
           </execution>
         </executions>
       </plugin>
-      <!-- 
-      <plugin>
-        <groupId>incubator-activemq</groupId>
-        <artifactId>maven-activemq-perf-plugin</artifactId>
-        <version>4.0-SNAPSHOT</version>
-        <configuration>
-          <configFile>src/release/conf/activemq.xml</configFile>
-        </configuration>
-      </plugin>
-      -->
     </plugins>
   </build>
 
-</project>
+</project>
\ No newline at end of file

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=412301&r1=412300&r2=412301&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
Tue Jun  6 23:17:14 2006
@@ -93,32 +93,32 @@
     private String destComposite;
 
     /**
-     * @parameter expression="${consumer.durable}" default-value="false"
+     * @parameter expression="${client.durable}" default-value="false"
      * @required
      */
     private String durable;
 
     /**
-     * @parameter expression="${consumer.asyncRecv}" default-value="true"
+     * @parameter expression="${client.asyncRecv}" default-value="true"
      * @required
      */
     private String asyncRecv;
 
     /**
-     * @parameter expression="${consumer.recvCount}" default-value="1000"
+     * @parameter expression="${client.recvCount}" default-value="1000"
      * @required
      */
     private String recvCount;
 
     /*
-     * @parameter expression="${consumer.recvDuration}" default-value="60000"
+     * @parameter expression="${client.recvDuration}" default-value="60000"
      * @required
 
     private String recvDuration;
     */
 
     /**
-     * @parameter expression="${consumer.recvType}" default-value="time"
+     * @parameter expression="${client.recvType}" default-value="time"
      * @required
      */
     private String recvType;
@@ -209,11 +209,11 @@
         options[8] = "client.destCount=" + destCount;
         options[9] = "client.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[10] = "client.durable=" + durable;
+        options[11] = "client.asyncRecv=" + asyncRecv;
+        options[12] = "client.recvCount=" + recvCount;     // 1000 messages
+        options[13] = "client.recvDuration=" + duration; // use sampler.duration.
+        options[14] = "client.recvType=" + recvType;
 
         options[15] = "factory.brokerUrl=" + brokerUrl;
         options[16] = "factory.optimAck=" + optimAck;

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=412301&r1=412300&r2=412301&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
Tue Jun  6 23:17:14 2006
@@ -91,26 +91,26 @@
     private String destComposite;
 
     /**
-     * @parameter expression="${producer.messageSize}" default-value="1024"
+     * @parameter expression="${client.messageSize}" default-value="1024"
      * @required
      */
     private String messageSize;
 
     /**
-     * @parameter expression="${producer.sendCount}" default-value="1000"
+     * @parameter expression="${client.sendCount}" default-value="1000"
      * @required
      */
     private String sendCount;
 
     /*
-     * @parameter expression="${producer.sendDuration}" default-value="60000"
+     * @parameter expression="${client.sendDuration}" default-value="60000"
      * @required
 
     private String sendDuration;
     */
 
     /**
-     * @parameter expression="${producer.sendType}" default-value="time"
+     * @parameter expression="${client.sendType}" default-value="time"
      * @required
      */
     private String sendType;
@@ -173,10 +173,10 @@
         options[8] = "client.destCount=" + destCount;
         options[9] = "client.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[10] = "client.messageSize="+messageSize;
+        options[11] = "client.sendCount="+sendCount;     // 1000 messages
+        options[12] = "client.sendDuration="+duration; // use sampler.duration.
+        options[13] = "client.sendType="+sendType;
 
         options[14] = "factory.brokerUrl="+brokerUrl;
         options[15] = "factory.asyncSend="+asyncSend;

Modified: incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfReportGenerator.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfReportGenerator.java?rev=412301&r1=412300&r2=412301&view=diff
==============================================================================
--- incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfReportGenerator.java
(original)
+++ incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/PerfReportGenerator.java
Tue Jun  6 23:17:14 2006
@@ -119,8 +119,8 @@
 
     public String createReportName(Properties testSettings) {
         if (testSettings != null) {
-            String[] keys = {"client.destCount", "consumer.asyncRecv", "consumer.durable",
-                             "producer.messageSize", "sysTest.numClients", "sysTest.totalDests"};
+            String[] keys = {"client.destCount", "client.asyncRecv", "client.durable",
+                             "client.messageSize", "sysTest.numClients", "sysTest.totalDests"};
 
             StringBuffer buffer = new StringBuffer();
             String key;



Mime
View raw message