git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1129225 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2011-05-30 15:44:58 +00:00
parent 861e26c297
commit da0b3b5335
3 changed files with 13 additions and 4 deletions

View File

@ -39,6 +39,8 @@
<property name="receive-time-out" value="0"/>
<property name="subscribers" value="1"/>
<property name="batch" value="10"/>
<property name="user" value=""/>
<property name="password" value=""/>
<!-- for WAR -->
<property name="app.name" value="activemq-web" />
@ -95,6 +97,8 @@
message consumption
parallelThreads - The number of parallel threads
batch - Batch size for transactions and client acknowledgment (default 10)
user - Connection username (if connecting to secured broker)
password - Connection password (if connecting to secured broker)
--------------------------------------------------------
ant producer &lt;options&gt; - Creates a producer publishing a number of messages
@ -116,7 +120,8 @@
verbose - Used to print out more info; the default is true
messageSize - The size of the message in 1-byte characters
parallelThreads - The number of parallel threads
user - Connection username (if connecting to secured broker)
password - Connection password (if connecting to secured broker)
--------------------------------------------------------
@ -221,6 +226,8 @@
<arg value="--ack-mode=${ack-mode}"/>
<arg value="--receive-time-out=${receive-time-out}"/>
<arg value="--batch=${batch}"/>
<arg value="--user=${user}"/>
<arg value="--password=${password}"/>
</java>
</target>
@ -241,7 +248,9 @@
<arg value="--time-to-live=${timeToLive}" />
<arg value="--sleep-time=${sleepTime}" />
<arg value="--transacted=${transacted}" />
<arg value="--verbose=${verbose}"/>
<arg value="--verbose=${verbose}"/>
<arg value="--user=${user}"/>
<arg value="--password=${password}"/>
</java>
</target>

View File

@ -111,7 +111,7 @@ public class ConsumerTool extends Thread implements MessageListener, ExceptionLi
}
public void showParameters() {
System.out.println("Connecting to URL: " + url);
System.out.println("Connecting to URL: " + url + " (" + user + ":" + password + ")");
System.out.println("Consuming " + (topic ? "topic" : "queue") + ": " + subject);
System.out.println("Using a " + (durable ? "durable" : "non-durable") + " subscription");
System.out.println("Running " + parallelThreads + " parallel threads");

View File

@ -90,7 +90,7 @@ public class ProducerTool extends Thread {
}
public void showParameters() {
System.out.println("Connecting to URL: " + url);
System.out.println("Connecting to URL: " + url + " (" + user + ":" + password + ")");
System.out.println("Publishing a Message with size " + messageSize + " to " + (topic ? "topic" : "queue") + ": " + subject);
System.out.println("Using " + (persistent ? "persistent" : "non-persistent") + " messages");
System.out.println("Sleeping between publish " + sleepTime + " ms");