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 String
getBrokerUrl()
String
getDestination()
String
getMessage()
int
getMessageCount()
int
getMessageSize()
String
getMsgGroupID()
long
getMsgTTL()
String
getName()
String
getOneLineDescription()
int
getParallelThreads()
String
getPassword()
String
getPayloadUrl()
int
getSleep()
int
getTextMessageSize()
int
getTransactionBatchSize()
String
getUser()
boolean
isPersistent()
protected void
printHelp()
Print the help messages for the specific taskprotected void
runTask(List<String> tokens)
Run the specific task.void
setBrokerUrl(String brokerUrl)
void
setDestination(String destination)
void
setMessage(String message)
void
setMessageCount(int messageCount)
void
setMessageSize(int messageSize)
void
setMsgGroupID(String msgGroupID)
void
setMsgTTL(long msgTTL)
void
setParallelThreads(int parallelThreads)
void
setPassword(String password)
void
setPayloadUrl(String payloadUrl)
void
setPersistent(boolean persistent)
void
setSleep(int sleep)
void
setTextMessageSize(int textMessageSize)
void
setTransactionBatchSize(int transactionBatchSize)
void
setUser(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:AbstractCommand
Run the specific task.- Specified by:
runTask
in 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:AbstractCommand
Print the help messages for the specific task- Specified by:
printHelp
in classAbstractCommand
-
getName
public String getName()
-
getOneLineDescription
public String getOneLineDescription()
-
-