public class ConsumerCommand extends AbstractCommand
COMMAND_OPTION_DELIMETER, context
Constructor and Description |
---|
ConsumerCommand() |
Modifier and Type | Method and 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) |
execute, handleOption, parseOptions, printHelpFromFile, setCommandContext
public ConsumerCommand()
protected void runTask(List<String> tokens) throws Exception
AbstractCommand
runTask
in class AbstractCommand
tokens
- - command argumentsException
public String getBrokerUrl()
public void setBrokerUrl(String brokerUrl)
public String getPassword()
public void setPassword(String password)
public String getDestination()
public void setDestination(String destination)
public int getMessageCount()
public void setMessageCount(int messageCount)
public int getSleep()
public void setSleep(int sleep)
public int getBatchSize()
public void setBatchSize(int batchSize)
public int getParallelThreads()
public void setParallelThreads(int parallelThreads)
public boolean isBytesAsText()
public void setBytesAsText(boolean bytesAsText)
public boolean isTransacted()
public void setTransacted(boolean transacted)
public int getAckMode()
public void setAckMode(String ackMode)
public boolean isDurable()
public void setDurable(boolean durable)
public String getClientId()
public void setClientId(String clientId)
protected void printHelp()
AbstractCommand
printHelp
in class AbstractCommand
public String getOneLineDescription()
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.