Package 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

acceptor, brokerURL, clientID, password, protocol, user

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

context, DEFAULT_BROKER_ACCEPTOR, DEFAULT_BROKER_URL, verbose

Constructor Summary

Constructors

Constructor	Description
DestAbstract()

Method Summary

Modifier and Type	Method	Description
String	getDestination()
protected javax.jms.Destination	getDestination(javax.jms.Session session)
static javax.jms.Destination	getDestination(javax.jms.Session session, String destination)
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)
static String	stripPrefix(String destination)

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

createConnectionFactory, createConnectionFactory, createCoreConnectionFactory, createCoreConnectionFactory, execute, getAcceptor, getBrokerURL, getClientID, getPassword, getProtocol, getUser, setAcceptor, setBrokerURL, setClientID, setPassword, setProtocol, setUser

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

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

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

checkOptions, getBrokerConfiguration, getBrokerEtc, getBrokerHome, getBrokerInstance, getBrokerURIInstance, getBrokerURLInstance, 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 javax.jms.Destination getDestination(javax.jms.Session session)
                                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getDestination

public static javax.jms.Destination getDestination(javax.jms.Session session,
                                                   String destination)
                                            throws javax.jms.JMSException

Throws:

javax.jms.JMSException

stripPrefix

public static String stripPrefix(String destination)

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)