activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a..@apache.org
Subject svn commit: r412371 - 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 11:34:27 GMT
Author: aco
Date: Wed Jun  7 04:34:27 2006
New Revision: 412371

URL: http://svn.apache.org/viewvc?rev=412371&view=rev
Log:
Change client prefix to consumer and producer prefix respectively.

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=412371&r1=412370&r2=412371&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 04:34:27 2006
@@ -57,68 +57,68 @@
     private String rampDownTime;
 
     /**
-     * @parameter expression="${client.spiClass}" default-value="org.apache.activemq.tool.spi.ActiveMQPojoSPI"
+     * @parameter expression="${consumer.spiClass}" default-value="org.apache.activemq.tool.spi.ActiveMQPojoSPI"
      * @required
      */
     private String spiClass;
 
     /**
-     * @parameter expression="${client.sessTransacted}" default-value="false"
+     * @parameter expression="${consumer.sessTransacted}" default-value="false"
      * @required
      */
     private String sessTransacted;
 
     /**
-     * @parameter expression="${client.sessAckMode}" default-value="autoAck"
+     * @parameter expression="${consumer.sessAckMode}" default-value="autoAck"
      * @required
      */
     private String sessAckMode;
 
     /**
-     * @parameter expression="${client.destName}" default-value="topic://FOO.BAR.TEST"
+     * @parameter expression="${consumer.destName}" default-value="topic://FOO.BAR.TEST"
      * @required
      */
     private String destName;
 
     /**
-     * @parameter expression="${client.destCount}" default-value="1"
+     * @parameter expression="${consumer.destCount}" default-value="1"
      * @required
      */
     private String destCount;
 
     /**
-     * @parameter expression="${client.destComposite}" default-value="false"
+     * @parameter expression="${consumer.destComposite}" default-value="false"
      * @required
      */
     private String destComposite;
 
     /**
-     * @parameter expression="${client.durable}" default-value="false"
+     * @parameter expression="${consumer.durable}" default-value="false"
      * @required
      */
     private String durable;
 
     /**
-     * @parameter expression="${client.asyncRecv}" default-value="true"
+     * @parameter expression="${consumer.asyncRecv}" default-value="true"
      * @required
      */
     private String asyncRecv;
 
     /**
-     * @parameter expression="${client.recvCount}" default-value="1000"
+     * @parameter expression="${consumer.recvCount}" default-value="1000"
      * @required
      */
     private String recvCount;
 
     /*
-     * @parameter expression="${client.recvDuration}" default-value="60000"
+     * @parameter expression="${consumer.recvDuration}" default-value="60000"
      * @required
 
     private String recvDuration;
     */
 
     /**
-     * @parameter expression="${client.recvType}" default-value="time"
+     * @parameter expression="${consumer.recvType}" default-value="time"
      * @required
      */
     private String recvType;
@@ -202,18 +202,18 @@
         options[2] = "sampler.rampUpTime=" + rampUpTime;   // 10 secs
         options[3] = "sampler.rampDownTime=" + rampDownTime; // 10 secs
 
-        options[4] = "client.spiClass=" + spiClass;
-        options[5] = "client.sessTransacted=" + sessTransacted;
-        options[6] = "client.sessAckMode=" + sessAckMode;
-        options[7] = "client.destName=" + destName;
-        options[8] = "client.destCount=" + destCount;
-        options[9] = "client.destComposite=" + destComposite;
-
-        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[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;

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=412371&r1=412370&r2=412371&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 04:34:27 2006
@@ -55,62 +55,62 @@
     private String rampDownTime;
 
     /**
-     * @parameter expression="${client.spiClass}" default-value="org.apache.activemq.tool.spi.ActiveMQPojoSPI"
+     * @parameter expression="${producer.spiClass}" default-value="org.apache.activemq.tool.spi.ActiveMQPojoSPI"
      * @required
      */
     private String spiClass;
 
     /**
-     * @parameter expression="${client.sessTransacted}" default-value="false"
+     * @parameter expression="${producer.sessTransacted}" default-value="false"
      * @required
      */
     private String sessTransacted;
 
     /**
-     * @parameter expression="${client.sessAckMode}" default-value="autoAck"
+     * @parameter expression="${producer.sessAckMode}" default-value="autoAck"
      * @required
      */
     private String sessAckMode;
 
     /**
-     * @parameter expression="${client.destName}" default-value="topic://FOO.BAR.TEST"
+     * @parameter expression="${producer.destName}" default-value="topic://FOO.BAR.TEST"
      * @required
      */
     private String destName;
 
     /**
-     * @parameter expression="${client.destCount}" default-value="1"
+     * @parameter expression="${producer.destCount}" default-value="1"
      * @required
      */
     private String destCount;
 
     /**
-     * @parameter expression="${client.destComposite}" default-value="false"
+     * @parameter expression="${producer.destComposite}" default-value="false"
      * @required
      */
     private String destComposite;
 
     /**
-     * @parameter expression="${client.messageSize}" default-value="1024"
+     * @parameter expression="${producer.messageSize}" default-value="1024"
      * @required
      */
     private String messageSize;
 
     /**
-     * @parameter expression="${client.sendCount}" default-value="1000"
+     * @parameter expression="${producer.sendCount}" default-value="1000"
      * @required
      */
     private String sendCount;
 
     /*
-     * @parameter expression="${client.sendDuration}" default-value="60000"
+     * @parameter expression="${producer.sendDuration}" default-value="60000"
      * @required
 
     private String sendDuration;
     */
 
     /**
-     * @parameter expression="${client.sendType}" default-value="time"
+     * @parameter expression="${producer.sendType}" default-value="time"
      * @required
      */
     private String sendType;
@@ -166,17 +166,17 @@
         options[2] = "sampler.rampUpTime=" + rampUpTime;   // 10 secs
         options[3] = "sampler.rampDownTime=" + rampDownTime; // 10 secs
 
-        options[4] = "client.spiClass=" + spiClass;
-        options[5] = "client.sessTransacted=" + sessTransacted;
-        options[6] = "client.sessAckMode=" + sessAckMode;
-        options[7] = "client.destName=" + destName;
-        options[8] = "client.destCount=" + destCount;
-        options[9] = "client.destComposite=" + destComposite;
-
-        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[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;



Mime
View raw message