org.apache.activemq.console.command

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 and Description
ProducerCommand()

Method Summary

Modifier and Type	Method and 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 task
protected 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProducerCommand

public ProducerCommand()

Method Detail

runTask

protected void runTask(List<String> tokens)
                throws Exception

Description copied from class: AbstractCommand

Run the specific task.

Specified by:

runTask in class AbstractCommand

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 class AbstractCommand

getName

public String getName()

getOneLineDescription

public String getOneLineDescription()