Class ProducerCommand
- java.lang.Object
-
- org.apache.activemq.console.command.AbstractCommand
-
- org.apache.activemq.console.command.ProducerCommand
-
- All Implemented Interfaces:
Command
public class ProducerCommand extends AbstractCommand
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.console.command.AbstractCommand
COMMAND_OPTION_DELIMETER, context
-
-
Constructor Summary
Constructors Constructor Description ProducerCommand()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringgetBrokerUrl()StringgetDestination()StringgetMessage()intgetMessageCount()intgetMessageSize()StringgetMsgGroupID()longgetMsgTTL()StringgetName()StringgetOneLineDescription()intgetParallelThreads()StringgetPassword()StringgetPayloadUrl()intgetSleep()intgetTextMessageSize()intgetTransactionBatchSize()StringgetUser()booleanisPersistent()protected voidprintHelp()Print the help messages for the specific taskprotected voidrunTask(List<String> tokens)Run the specific task.voidsetBrokerUrl(String brokerUrl)voidsetDestination(String destination)voidsetMessage(String message)voidsetMessageCount(int messageCount)voidsetMessageSize(int messageSize)voidsetMsgGroupID(String msgGroupID)voidsetMsgTTL(long msgTTL)voidsetParallelThreads(int parallelThreads)voidsetPassword(String password)voidsetPayloadUrl(String payloadUrl)voidsetPersistent(boolean persistent)voidsetSleep(int sleep)voidsetTextMessageSize(int textMessageSize)voidsetTransactionBatchSize(int transactionBatchSize)voidsetUser(String user)-
Methods inherited from class org.apache.activemq.console.command.AbstractCommand
execute, handleException, handleOption, parseOptions, printHelpFromFile, setCommandContext
-
-
-
-
Method Detail
-
runTask
protected void runTask(List<String> tokens) throws Exception
Description copied from class:AbstractCommandRun the specific task.- Specified by:
runTaskin classAbstractCommand- Parameters:
tokens- - command arguments- Throws:
Exception
-
getBrokerUrl
public String getBrokerUrl()
-
setBrokerUrl
public void setBrokerUrl(String brokerUrl)
-
getDestination
public String getDestination()
-
setDestination
public void setDestination(String destination)
-
getMessageCount
public int getMessageCount()
-
setMessageCount
public void setMessageCount(int messageCount)
-
getSleep
public int getSleep()
-
setSleep
public void setSleep(int sleep)
-
isPersistent
public boolean isPersistent()
-
setPersistent
public void setPersistent(boolean persistent)
-
getMessageSize
public int getMessageSize()
-
setMessageSize
public void setMessageSize(int messageSize)
-
getTextMessageSize
public int getTextMessageSize()
-
setTextMessageSize
public void setTextMessageSize(int textMessageSize)
-
getMsgTTL
public long getMsgTTL()
-
setMsgTTL
public void setMsgTTL(long msgTTL)
-
getMsgGroupID
public String getMsgGroupID()
-
setMsgGroupID
public void setMsgGroupID(String msgGroupID)
-
getTransactionBatchSize
public int getTransactionBatchSize()
-
setTransactionBatchSize
public void setTransactionBatchSize(int transactionBatchSize)
-
getUser
public String getUser()
-
setUser
public void setUser(String user)
-
getPassword
public String getPassword()
-
setPassword
public void setPassword(String password)
-
getParallelThreads
public int getParallelThreads()
-
setParallelThreads
public void setParallelThreads(int parallelThreads)
-
getPayloadUrl
public String getPayloadUrl()
-
setPayloadUrl
public void setPayloadUrl(String payloadUrl)
-
getMessage
public String getMessage()
-
setMessage
public void setMessage(String message)
-
printHelp
protected void printHelp()
Description copied from class:AbstractCommandPrint the help messages for the specific task- Specified by:
printHelpin classAbstractCommand
-
getName
public String getName()
-
getOneLineDescription
public String getOneLineDescription()
-
-