Class PerfClientCommand

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.perf.PerfCommand

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

All Implemented Interfaces:

Runnable, Action

public class PerfClientCommand
extends PerfCommand

Field Summary

Fields

Modifier and Type	Field	Description
protected int	consumerConnections
protected ConnectionProtocol	consumerProtocol
protected int	consumersPerDestination
protected String	consumerUrl
protected boolean	durableSubscription
protected boolean	enableMessageID
protected boolean	enableTimestamp
protected long	maxPending
protected int	messageSize
protected String	msgGroupID
protected boolean	persistent
protected int	producersPerDestination
protected Long	rate
protected boolean	sharedConnections
protected int	sharedSubscription
protected int	threads
protected boolean	transaction
protected long	ttl

Fields inherited from class PerfCommand

commitInterval, destinations, duration, hdrFileName, messageCount, numDestinations, reportFileName, showLatency, txSize, warmup

Fields inherited from class ConnectionAbstract

clientID, protocol

Fields inherited from class ConnectionConfigurationAbtract

acceptor, brokerURL, CONNECTION_INFORMATION, password, silent, user

Fields inherited from class ActionAbstract

DEFAULT_BROKER_ACCEPTOR, DEFAULT_BROKER_URL, verbose

Constructor Summary

Constructors

Constructor	Description
PerfClientCommand()

Method Summary

Modifier and Type	Method	Description
Object	execute(ActionContext context)
int	getConsumerConnections()
String	getConsumerProtocol()
int	getConsumersPerDestination()
String	getConsumerUrl()
long	getMaxPending()
int	getMessageSize()
String	getMsgGroupID()
BenchmarkService	getProducerBenchmark()
int	getProducersPerDestination()
Long	getRate()
int	getSharedSubscription()
int	getThreads()
long	getTtl()
boolean	isDurableSubscription()
boolean	isEnableMessageID()
boolean	isEnableTimestamp()
boolean	isPersistent()
boolean	isSharedConnections()
boolean	isTransaction()
protected void	onExecuteBenchmark(javax.jms.ConnectionFactory producerConnectionFactory, javax.jms.Destination[] jmsDestinations, ActionContext context)
protected void	onInterruptBenchmark()
PerfClientCommand	setConsumerConnections(int consumerConnections)
PerfClientCommand	setConsumerProtocol(String consumerProtocol)
PerfClientCommand	setConsumersPerDestination(int consumersPerDestination)
PerfClientCommand	setConsumerUrl(String consumerUrl)
PerfClientCommand	setDurableSubscription(boolean durableSubscription)
PerfClientCommand	setEnableMessageID(boolean enableMessageID)
PerfClientCommand	setEnableTimestamp(boolean enableTimestamp)
PerfClientCommand	setMaxPending(long maxPending)
PerfClientCommand	setMessageSize(int messageSize)
PerfClientCommand	setMsgGroupID(String msgGroupID)
PerfClientCommand	setPersistent(boolean persistent)
PerfClientCommand	setProducerBenchmark(BenchmarkService producerBenchmark)
PerfClientCommand	setProducersPerDestination(int producersPerDestination)
PerfClientCommand	setRate(Long rate)
PerfClientCommand	setSharedConnections(boolean sharedConnections)
PerfClientCommand	setSharedSubscription(int sharedSubscription)
PerfClientCommand	setThreads(int threads)
PerfClientCommand	setTransaction(boolean transaction)
PerfClientCommand	setTtl(long ttl)

Methods inherited from class PerfCommand

collectAndReportStatisticsWhileRunning, getCompleted, getDestinations, getDuration, getHdrFileName, getMessageCount, getNumDestinations, getReportFileName, getWarmup, isShowLatency, lookupDestinations, setDestinations, setDuration, setHdrFileName, setMessageCount, setNumDestinations, setReportFileName, setShowLatency, setWarmup

Methods inherited from class ConnectionAbstract

createConnectionFactory, createConnectionFactory, createCoreConnectionFactory, createCoreConnectionFactory, getClientID, getProtocol, performCoreManagement, performCoreManagement, setClientID, setProtocol, setProtocol, tryConnect

Methods inherited from class ConnectionConfigurationAbtract

getAcceptor, getBrokerURL, getPassword, getUser, inputBrokerURL, inputPassword, inputUser, recoverConnectionInformation, saveConnectionInfo, setAcceptor, setBrokerURL, setPassword, setUser

Methods inherited from class InputAbstract

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

Methods inherited from class ActionAbstract

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

Methods inherited from class Object

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

Field Details

transaction

protected boolean transaction

sharedSubscription

protected int sharedSubscription

durableSubscription

protected boolean durableSubscription

consumerConnections

protected int consumerConnections

consumersPerDestination

protected int consumersPerDestination

persistent

protected boolean persistent

messageSize

protected int messageSize

rate

protected Long rate

ttl

protected long ttl

msgGroupID

protected String msgGroupID

sharedConnections

protected boolean sharedConnections

producersPerDestination

protected int producersPerDestination

threads

protected int threads

maxPending

protected long maxPending

consumerUrl

protected String consumerUrl

consumerProtocol

protected ConnectionProtocol consumerProtocol

enableMessageID

protected boolean enableMessageID

enableTimestamp

protected boolean enableTimestamp

Constructor Details

PerfClientCommand

public PerfClientCommand()

Method Details

onExecuteBenchmark

protected void onExecuteBenchmark(javax.jms.ConnectionFactory producerConnectionFactory,
 javax.jms.Destination[] jmsDestinations,
 ActionContext context)
                           throws Exception

Specified by:

onExecuteBenchmark in class PerfCommand

Throws:

Exception

onInterruptBenchmark

protected void onInterruptBenchmark()

Specified by:

onInterruptBenchmark in class PerfCommand

execute

public Object execute(ActionContext context)
               throws Exception

Specified by:

execute in interface Action

Overrides:

execute in class PerfCommand

Throws:

Exception

isTransaction

public boolean isTransaction()

setTransaction

public PerfClientCommand setTransaction(boolean transaction)

getSharedSubscription

public int getSharedSubscription()

setSharedSubscription

public PerfClientCommand setSharedSubscription(int sharedSubscription)

isDurableSubscription

public boolean isDurableSubscription()

setDurableSubscription

public PerfClientCommand setDurableSubscription(boolean durableSubscription)

getConsumerConnections

public int getConsumerConnections()

setConsumerConnections

public PerfClientCommand setConsumerConnections(int consumerConnections)

getConsumersPerDestination

public int getConsumersPerDestination()

setConsumersPerDestination

public PerfClientCommand setConsumersPerDestination(int consumersPerDestination)

isPersistent

public boolean isPersistent()

setPersistent

public PerfClientCommand setPersistent(boolean persistent)

getMessageSize

public int getMessageSize()

setMessageSize

public PerfClientCommand setMessageSize(int messageSize)

getRate

public Long getRate()

setRate

public PerfClientCommand setRate(Long rate)

getTtl

public long getTtl()

setTtl

public PerfClientCommand setTtl(long ttl)

getMsgGroupID

public String getMsgGroupID()

setMsgGroupID

public PerfClientCommand setMsgGroupID(String msgGroupID)

isSharedConnections

public boolean isSharedConnections()

setSharedConnections

public PerfClientCommand setSharedConnections(boolean sharedConnections)

getProducersPerDestination

public int getProducersPerDestination()

setProducersPerDestination

public PerfClientCommand setProducersPerDestination(int producersPerDestination)

getThreads

public int getThreads()

setThreads

public PerfClientCommand setThreads(int threads)

getMaxPending

public long getMaxPending()

setMaxPending

public PerfClientCommand setMaxPending(long maxPending)

getConsumerUrl

public String getConsumerUrl()

setConsumerUrl

public PerfClientCommand setConsumerUrl(String consumerUrl)

getConsumerProtocol

public String getConsumerProtocol()

setConsumerProtocol

public PerfClientCommand setConsumerProtocol(String consumerProtocol)

isEnableMessageID

public boolean isEnableMessageID()

setEnableMessageID

public PerfClientCommand setEnableMessageID(boolean enableMessageID)

isEnableTimestamp

public boolean isEnableTimestamp()

setEnableTimestamp

public PerfClientCommand setEnableTimestamp(boolean enableTimestamp)

getProducerBenchmark

public BenchmarkService getProducerBenchmark()

setProducerBenchmark

public PerfClientCommand setProducerBenchmark(BenchmarkService producerBenchmark)