public class ProducerCommand extends AbstractCommand
COMMAND_OPTION_DELIMETER, context
Constructor and Description |
---|
ProducerCommand() |
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) |
execute, handleException, handleOption, parseOptions, printHelpFromFile, setCommandContext
public ProducerCommand()
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 getDestination()
public void setDestination(String destination)
public int getMessageCount()
public void setMessageCount(int messageCount)
public int getSleep()
public void setSleep(int sleep)
public boolean isPersistent()
public void setPersistent(boolean persistent)
public int getMessageSize()
public void setMessageSize(int messageSize)
public int getTextMessageSize()
public void setTextMessageSize(int textMessageSize)
public long getMsgTTL()
public void setMsgTTL(long msgTTL)
public String getMsgGroupID()
public void setMsgGroupID(String msgGroupID)
public int getTransactionBatchSize()
public void setTransactionBatchSize(int transactionBatchSize)
public String getPassword()
public void setPassword(String password)
public int getParallelThreads()
public void setParallelThreads(int parallelThreads)
public String getPayloadUrl()
public void setPayloadUrl(String payloadUrl)
public String getMessage()
public void setMessage(String message)
protected void printHelp()
AbstractCommand
printHelp
in class AbstractCommand
public String getOneLineDescription()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.