Package org.apache.activemq.console.command

Class ConsumerCommand

java.lang.Object

org.apache.activemq.console.command.AbstractCommand

org.apache.activemq.console.command.ConsumerCommand

All Implemented Interfaces:

Command

public class ConsumerCommand
extends AbstractCommand

Field Summary

Fields inherited from class org.apache.activemq.console.command.AbstractCommand

COMMAND_OPTION_DELIMETER, context

Constructor Summary

Constructors

Constructor	Description
ConsumerCommand()

Method Summary

Modifier and Type	Method	Description
int	getAckMode()
int	getBatchSize()
String	getBrokerUrl()
String	getClientId()
String	getDestination()
int	getMessageCount()
String	getName()
String	getOneLineDescription()
int	getParallelThreads()
String	getPassword()
int	getSleep()
String	getUser()
boolean	isBytesAsText()
boolean	isDurable()
boolean	isTransacted()
protected void	printHelp()	Print the help messages for the specific task
protected void	runTask(List<String> tokens)	Run the specific task.
void	setAckMode(String ackMode)
void	setBatchSize(int batchSize)
void	setBrokerUrl(String brokerUrl)
void	setBytesAsText(boolean bytesAsText)
void	setClientId(String clientId)
void	setDestination(String destination)
void	setDurable(boolean durable)
void	setMessageCount(int messageCount)
void	setParallelThreads(int parallelThreads)
void	setPassword(String password)
void	setSleep(int sleep)
void	setTransacted(boolean transacted)
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

ConsumerCommand

public ConsumerCommand()

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)

getUser

public String getUser()

setUser

public void setUser(String user)

getPassword

public String getPassword()

setPassword

public void setPassword(String password)

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)

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

getParallelThreads

public int getParallelThreads()

setParallelThreads

public void setParallelThreads(int parallelThreads)

isBytesAsText

public boolean isBytesAsText()

setBytesAsText

public void setBytesAsText(boolean bytesAsText)

isTransacted

public boolean isTransacted()

setTransacted

public void setTransacted(boolean transacted)

getAckMode

public int getAckMode()

setAckMode

public void setAckMode(String ackMode)

isDurable

public boolean isDurable()

setDurable

public void setDurable(boolean durable)

getClientId

public String getClientId()

setClientId

public void setClientId(String clientId)

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()