Package org.apache.activemq.tool

Class AbstractJmsMeasurableClient

java.lang.Object

org.apache.activemq.tool.AbstractJmsClient

org.apache.activemq.tool.AbstractJmsMeasurableClient

All Implemented Interfaces:

MeasurableClient

Direct Known Subclasses:

JmsConsumerClient, JmsProducerClient

public abstract class AbstractJmsMeasurableClient
extends AbstractJmsClient
implements MeasurableClient

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicLong	throughput

Fields inherited from class org.apache.activemq.tool.AbstractJmsClient

clientName, destCount, DESTINATION_SEPARATOR, destIndex, factory, jmsConnection, jmsSession

Constructor Summary

Constructors

Constructor	Description
AbstractJmsMeasurableClient(ConnectionFactory factory)

Method Summary

Modifier and Type	Method	Description
long	getThroughput()
void	incThroughput()
void	incThroughput(long val)
void	reset()
void	setThroughput(long val)

Methods inherited from class org.apache.activemq.tool.AbstractJmsClient

commitTxIfNecessary, createCompositeDestination, createCompositeDestination, createDestination, createDestinations, createTemporaryDestination, getClient, getClientName, getConnection, getDestCount, getDestinationType, getDestIndex, getFactory, getSession, getSimpleName, setClient, setClientName, setDestCount, setDestIndex, setFactory

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.tool.sampler.MeasurableClient

getClientName

Field Detail

throughput

protected AtomicLong throughput

Constructor Detail

AbstractJmsMeasurableClient

public AbstractJmsMeasurableClient(ConnectionFactory factory)

Method Detail

reset

public void reset()

Specified by:

reset in interface MeasurableClient

getThroughput

public long getThroughput()

Specified by:

getThroughput in interface MeasurableClient

setThroughput

public void setThroughput(long val)

incThroughput

public void incThroughput()

incThroughput

public void incThroughput(long val)