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.ConnectionConfigurationAbtract

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

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

All Implemented Interfaces:

Runnable, Action

Direct Known Subclasses:

Browse, Consumer, Producer

public class DestAbstract
extends ConnectionAbstract

Field Summary

Fields

Modifier and Type	Field	Description
protected int	txBatchSize

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

clientID, protocol

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

acceptor, brokerURL, CONNECTION_INFORMATION, password, silent, user

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

DEFAULT_BROKER_ACCEPTOR, DEFAULT_BROKER_URL, verbose

Constructor Summary

Constructors

Constructor	Description
DestAbstract()

Method Summary

Modifier and Type	Method	Description
Object	execute(ActionContext context)
String	getDestination()
protected javax.jms.Destination	getDestination(javax.jms.Session session)
static javax.jms.Destination	getDestination(javax.jms.Session session, String destination)
long	getMessageCount()
protected MessageSerializer	getMessageSerializer()
String	getSerializer()
int	getSleep()
int	getThreads()
int	getTxBatchSize()
DestAbstract	setDestination(String destination)
DestAbstract	setMessageCount(long 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, getClientID, getProtocol, performCoreManagement, performCoreManagement, setClientID, setProtocol, setProtocol, tryConnect

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

getAcceptor, getBrokerURL, getPassword, getUser, inputBrokerURL, inputPassword, inputUser, recoverConnectionInformation, saveConnectionInfo, setAcceptor, setBrokerURL, setPassword, 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

done, getActionContext, getBrokerConfiguration, getBrokerEtc, getBrokerHome, getBrokerInstance, getBrokerURIInstance, getBrokerURLInstance, isVerbose, run, setHomeValues

Methods inherited from class java.lang.Object

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

Field Details

txBatchSize

protected int txBatchSize

Constructor Details

DestAbstract

public DestAbstract()

Method Details

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

setMessageCount

public DestAbstract setMessageCount(long 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)

execute

public Object execute(ActionContext context)
               throws Exception

Specified by:

execute in interface Action

Overrides:

execute in class ConnectionConfigurationAbtract

Throws:

Exception