org.apache.activemq.artemis.cli.commands.messages

Class DestAbstract

java.lang.Object

org.apache.activemq.artemis.cli.commands.ActionAbstract

org.apache.activemq.artemis.cli.commands.InputAbstract

org.apache.activemq.artemis.cli.commands.messages.ConnectionAbstract

org.apache.activemq.artemis.cli.commands.messages.DestAbstract

All Implemented Interfaces:

Action

Direct Known Subclasses:

Browse, Consumer, Producer

public class DestAbstract
extends ConnectionAbstract

Field Summary

Fields inherited from class org.apache.activemq.artemis.cli.commands.messages.ConnectionAbstract

brokerURL, password, user

Fields inherited from class org.apache.activemq.artemis.cli.commands.ActionAbstract

context, verbose

Constructor Summary

Constructors

Constructor and Description
DestAbstract()

Method Summary

Modifier and Type	Method and Description
String	getDestination()
protected Destination	getDestination(Session session)
int	getMessageCount()
protected MessageSerializer	getMessageSerializer()
String	getSerializer()
int	getSleep()
int	getThreads()
int	getTxBatchSize()
DestAbstract	setDestination(String destination)
DestAbstract	setMessageCount(int messageCount)
DestAbstract	setSerializer(String serializer)
DestAbstract	setSleep(int sleep)
DestAbstract	setThreads(int threads)
DestAbstract	setTxBatchSize(int txBatchSize)

Methods inherited from class org.apache.activemq.artemis.cli.commands.messages.ConnectionAbstract

createConnectionFactory, createCoreConnectionFactory, execute, getClientID, getPassword, getProtocol, getUser, setClientID, setPassword, setProtocol, setUser

Methods inherited from class org.apache.activemq.artemis.cli.commands.InputAbstract

enableInput, input, input, inputBoolean, inputPassword, isSilentInput, setSilentInput

Methods inherited from class org.apache.activemq.artemis.cli.commands.ActionAbstract

checkOptions, getBrokerEtc, getBrokerHome, getBrokerInstance, getBrokerURIInstance, isVerbose, setHomeValues

Methods inherited from class java.lang.Object

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

Constructor Detail

DestAbstract

public DestAbstract()

Method Detail

getMessageSerializer

protected MessageSerializer getMessageSerializer()

getDestination

protected Destination getDestination(Session session)
                              throws JMSException

Throws:

JMSException

getDestination

public String getDestination()

setDestination

public DestAbstract setDestination(String destination)

getMessageCount

public int getMessageCount()

setMessageCount

public DestAbstract setMessageCount(int messageCount)

getSleep

public int getSleep()

setSleep

public DestAbstract setSleep(int sleep)

getTxBatchSize

public int getTxBatchSize()

setTxBatchSize

public DestAbstract setTxBatchSize(int txBatchSize)

getThreads

public int getThreads()

setThreads

public DestAbstract setThreads(int threads)

getSerializer

public String getSerializer()

setSerializer

public DestAbstract setSerializer(String serializer)