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

This closes #1424

This commit is contained in:
Justin Bertram 2017-07-28 09:15:03 -05:00
parent e316c920b4 4edb750165
commit 40534b29d6
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/Browse.java
View File

@ -27,7 +27,7 @@ import org.apache.activemq.artemis.cli.commands.ActionContext;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.jms.client.ActiveMQDestination; import org.apache.activemq.artemis.jms.client.ActiveMQDestination;
@Command(name = "browser", description = "It will send consume messages from an instance") @Command(name = "browser", description = "It will browse messages on an instance")
public class Browse extends DestAbstract { public class Browse extends DestAbstract {
@Option(name = "--filter", description = "filter to be used with the consumer") @Option(name = "--filter", description = "filter to be used with the consumer")

2
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/Consumer.java
View File

@ -27,7 +27,7 @@ import org.apache.activemq.artemis.cli.commands.ActionContext;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.jms.client.ActiveMQDestination; import org.apache.activemq.artemis.jms.client.ActiveMQDestination;
@Command(name = "consumer", description = "It will send consume messages from an instance") @Command(name = "consumer", description = "It will consume messages from an instance")
public class Consumer extends DestAbstract { public class Consumer extends DestAbstract {
@Option(name = "--durable", description = "It will use durable subscription in case of client") @Option(name = "--durable", description = "It will use durable subscription in case of client")

2
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/DestAbstract.java
View File

@ -21,7 +21,7 @@ import io.airlift.airline.Option;
public class DestAbstract extends ConnectionAbstract { public class DestAbstract extends ConnectionAbstract {
@Option(name = "--destination", description = "Destination to be used. it could be prefixed with queue:// or topic:: (Default: queue://TEST") @Option(name = "--destination", description = "Destination to be used. It can be prefixed with queue:// or topic:// (Default: queue://TEST)")
String destination = "queue://TEST"; String destination = "queue://TEST";
@Option(name = "--message-count", description = "Number of messages to act on (Default: 1000)") @Option(name = "--message-count", description = "Number of messages to act on (Default: 1000)")

2
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/Producer.java
View File

@ -36,7 +36,7 @@ public class Producer extends DestAbstract {
@Option(name = "--message-size", description = "Size of each byteMessage (The producer will use byte message on this case)") @Option(name = "--message-size", description = "Size of each byteMessage (The producer will use byte message on this case)")
int messageSize = 0; int messageSize = 0;
@Option(name = "--text-size", description = "Size of each textNessage (The producer will use text message on this case)") @Option(name = "--text-size", description = "Size of each textMessage (The producer will use text message on this case)")
int textMessageSize; int textMessageSize;
@Option(name = "--msgttl", description = "TTL for each message") @Option(name = "--msgttl", description = "TTL for each message")