Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Change client prefix to consumer and producer prefix respectively. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412371 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Adrian T. Co 2006-06-07 11:34:27 +00:00
parent ec74dd845c
commit 51eed37625
2 changed files with 42 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ConsumerMojo.java
View File

@ -57,68 +57,68 @@ public class ConsumerMojo
private String rampDownTime; 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 * @required
*/ */
private String spiClass; private String spiClass;
/** /**
* @parameter expression="${client.sessTransacted}" default-value="false" * @parameter expression="${consumer.sessTransacted}" default-value="false"
* @required * @required
*/ */
private String sessTransacted; private String sessTransacted;
/** /**
* @parameter expression="${client.sessAckMode}" default-value="autoAck" * @parameter expression="${consumer.sessAckMode}" default-value="autoAck"
* @required * @required
*/ */
private String sessAckMode; private String sessAckMode;
/** /**
* @parameter expression="${client.destName}" default-value="topic://FOO.BAR.TEST" * @parameter expression="${consumer.destName}" default-value="topic://FOO.BAR.TEST"
* @required * @required
*/ */
private String destName; private String destName;
/** /**
* @parameter expression="${client.destCount}" default-value="1" * @parameter expression="${consumer.destCount}" default-value="1"
* @required * @required
*/ */
private String destCount; private String destCount;
/** /**
* @parameter expression="${client.destComposite}" default-value="false" * @parameter expression="${consumer.destComposite}" default-value="false"
* @required * @required
*/ */
private String destComposite; private String destComposite;
/** /**
* @parameter expression="${client.durable}" default-value="false" * @parameter expression="${consumer.durable}" default-value="false"
* @required * @required
*/ */
private String durable; private String durable;
/** /**
* @parameter expression="${client.asyncRecv}" default-value="true" * @parameter expression="${consumer.asyncRecv}" default-value="true"
* @required * @required
*/ */
private String asyncRecv; private String asyncRecv;
/** /**
* @parameter expression="${client.recvCount}" default-value="1000" * @parameter expression="${consumer.recvCount}" default-value="1000"
* @required * @required
*/ */
private String recvCount; private String recvCount;
/* /*
* @parameter expression="${client.recvDuration}" default-value="60000" * @parameter expression="${consumer.recvDuration}" default-value="60000"
* @required * @required
private String recvDuration; private String recvDuration;
*/ */
/** /**
* @parameter expression="${client.recvType}" default-value="time" * @parameter expression="${consumer.recvType}" default-value="time"
* @required * @required
*/ */
private String recvType; private String recvType;
@ -202,18 +202,18 @@ public class ConsumerMojo
options[2] = "sampler.rampUpTime=" + rampUpTime; // 10 secs options[2] = "sampler.rampUpTime=" + rampUpTime; // 10 secs
options[3] = "sampler.rampDownTime=" + rampDownTime; // 10 secs options[3] = "sampler.rampDownTime=" + rampDownTime; // 10 secs
options[4] = "client.spiClass=" + spiClass; options[4] = "consumer.spiClass=" + spiClass;
options[5] = "client.sessTransacted=" + sessTransacted; options[5] = "consumer.sessTransacted=" + sessTransacted;
options[6] = "client.sessAckMode=" + sessAckMode; options[6] = "consumer.sessAckMode=" + sessAckMode;
options[7] = "client.destName=" + destName; options[7] = "consumer.destName=" + destName;
options[8] = "client.destCount=" + destCount; options[8] = "consumer.destCount=" + destCount;
options[9] = "client.destComposite=" + destComposite; options[9] = "consumer.destComposite=" + destComposite;
options[10] = "client.durable=" + durable; options[10] = "consumer.durable=" + durable;
options[11] = "client.asyncRecv=" + asyncRecv; options[11] = "consumer.asyncRecv=" + asyncRecv;
options[12] = "client.recvCount=" + recvCount; // 1000 messages options[12] = "consumer.recvCount=" + recvCount; // 1000 messages
options[13] = "client.recvDuration=" + duration; // use sampler.duration. options[13] = "consumer.recvDuration=" + duration; // use sampler.duration.
options[14] = "client.recvType=" + recvType; options[14] = "consumer.recvType=" + recvType;
options[15] = "factory.brokerUrl=" + brokerUrl; options[15] = "factory.brokerUrl=" + brokerUrl;
options[16] = "factory.optimAck=" + optimAck; options[16] = "factory.optimAck=" + optimAck;

40
tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/maven/ProducerMojo.java
View File

@ -55,62 +55,62 @@ public class ProducerMojo
private String rampDownTime; 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 * @required
*/ */
private String spiClass; private String spiClass;
/** /**
* @parameter expression="${client.sessTransacted}" default-value="false" * @parameter expression="${producer.sessTransacted}" default-value="false"
* @required * @required
*/ */
private String sessTransacted; private String sessTransacted;
/** /**
* @parameter expression="${client.sessAckMode}" default-value="autoAck" * @parameter expression="${producer.sessAckMode}" default-value="autoAck"
* @required * @required
*/ */
private String sessAckMode; private String sessAckMode;
/** /**
* @parameter expression="${client.destName}" default-value="topic://FOO.BAR.TEST" * @parameter expression="${producer.destName}" default-value="topic://FOO.BAR.TEST"
* @required * @required
*/ */
private String destName; private String destName;
/** /**
* @parameter expression="${client.destCount}" default-value="1" * @parameter expression="${producer.destCount}" default-value="1"
* @required * @required
*/ */
private String destCount; private String destCount;
/** /**
* @parameter expression="${client.destComposite}" default-value="false" * @parameter expression="${producer.destComposite}" default-value="false"
* @required * @required
*/ */
private String destComposite; private String destComposite;
/** /**
* @parameter expression="${client.messageSize}" default-value="1024" * @parameter expression="${producer.messageSize}" default-value="1024"
* @required * @required
*/ */
private String messageSize; private String messageSize;
/** /**
* @parameter expression="${client.sendCount}" default-value="1000" * @parameter expression="${producer.sendCount}" default-value="1000"
* @required * @required
*/ */
private String sendCount; private String sendCount;
/* /*
* @parameter expression="${client.sendDuration}" default-value="60000" * @parameter expression="${producer.sendDuration}" default-value="60000"
* @required * @required
private String sendDuration; private String sendDuration;
*/ */
/** /**
* @parameter expression="${client.sendType}" default-value="time" * @parameter expression="${producer.sendType}" default-value="time"
* @required * @required
*/ */
private String sendType; private String sendType;
@ -166,17 +166,17 @@ public class ProducerMojo
options[2] = "sampler.rampUpTime=" + rampUpTime; // 10 secs options[2] = "sampler.rampUpTime=" + rampUpTime; // 10 secs
options[3] = "sampler.rampDownTime=" + rampDownTime; // 10 secs options[3] = "sampler.rampDownTime=" + rampDownTime; // 10 secs
options[4] = "client.spiClass=" + spiClass; options[4] = "producer.spiClass=" + spiClass;
options[5] = "client.sessTransacted=" + sessTransacted; options[5] = "producer.sessTransacted=" + sessTransacted;
options[6] = "client.sessAckMode=" + sessAckMode; options[6] = "producer.sessAckMode=" + sessAckMode;
options[7] = "client.destName=" + destName; options[7] = "producer.destName=" + destName;
options[8] = "client.destCount=" + destCount; options[8] = "producer.destCount=" + destCount;
options[9] = "client.destComposite=" + destComposite; options[9] = "producer.destComposite=" + destComposite;
options[10] = "client.messageSize="+messageSize; options[10] = "producer.messageSize="+messageSize;
options[11] = "client.sendCount="+sendCount; // 1000 messages options[11] = "producer.sendCount="+sendCount; // 1000 messages
options[12] = "client.sendDuration="+duration; // use sampler.duration. options[12] = "producer.sendDuration="+duration; // use sampler.duration.
options[13] = "client.sendType="+sendType; options[13] = "producer.sendType="+sendType;
options[14] = "factory.brokerUrl="+brokerUrl; options[14] = "factory.brokerUrl="+brokerUrl;
options[15] = "factory.asyncSend="+asyncSend; options[15] = "factory.asyncSend="+asyncSend;