Package org.apache.activemq.tool

Class AbstractJmsClientSystem

java.lang.Object

org.apache.activemq.tool.properties.AbstractObjectProperties

org.apache.activemq.tool.AbstractJmsClientSystem

All Implemented Interfaces:

ReflectionConfigurable

Direct Known Subclasses:

JmsConsumerSystem, JmsProducerSystem

public abstract class AbstractJmsClientSystem
extends AbstractObjectProperties

Field Summary

Fields

Modifier and Type	Field	Description
protected ThreadGroup	clientThreadGroup
protected JmsFactoryProperties	factory
protected ConnectionFactory	jmsConnFactory
protected ThroughputSamplerTask	tpSampler

Constructor Summary

Constructors

Constructor	Description
AbstractJmsClientSystem()

Method Summary

Modifier and Type	Method	Description
protected PerformanceReportWriter	createPerfWriter()
protected void	distributeDestinations(String distroType, int clientIndex, int numClients, int numDests)
protected abstract ClientRunBasis	getClientRunBasis()
protected abstract long	getClientRunDuration()
JmsFactoryProperties	getFactory()
abstract JmsClientProperties	getJmsClientProperties()
abstract JmsClientSystemProperties	getSysTest()
ThroughputSamplerTask	getTpSampler()
protected ConnectionFactory	loadJmsFactory(String spiClass, Properties factorySettings)
protected static Properties	parseStringArgs(String[] args)
protected abstract void	runJmsClient(String clientName, int clientDestIndex, int clientDestCount)
void	runSystemTest()
void	setFactory(JmsFactoryProperties factory)
protected void	setProviderMetaData(ConnectionMetaData metaData, JmsClientProperties props)
abstract void	setSysTest(JmsClientSystemProperties sysTestProps)

Methods inherited from class org.apache.activemq.tool.properties.AbstractObjectProperties

acceptConfig, configureProperties, retrieveProperties

Methods inherited from class java.lang.Object

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

Field Detail

clientThreadGroup

protected ThreadGroup clientThreadGroup

jmsConnFactory

protected ConnectionFactory jmsConnFactory

factory

protected JmsFactoryProperties factory

tpSampler

protected ThroughputSamplerTask tpSampler

Constructor Detail

AbstractJmsClientSystem

public AbstractJmsClientSystem()

Method Detail

runSystemTest

public void runSystemTest()
                   throws JMSException

Throws:

JMSException

getClientRunBasis

protected abstract ClientRunBasis getClientRunBasis()

getClientRunDuration

protected abstract long getClientRunDuration()

getTpSampler

public ThroughputSamplerTask getTpSampler()

getFactory

public JmsFactoryProperties getFactory()

setFactory

public void setFactory(JmsFactoryProperties factory)

getSysTest

public abstract JmsClientSystemProperties getSysTest()

setSysTest

public abstract void setSysTest(JmsClientSystemProperties sysTestProps)

getJmsClientProperties

public abstract JmsClientProperties getJmsClientProperties()

createPerfWriter

protected PerformanceReportWriter createPerfWriter()

distributeDestinations

protected void distributeDestinations(String distroType,
                                      int clientIndex,
                                      int numClients,
                                      int numDests)

loadJmsFactory

protected ConnectionFactory loadJmsFactory(String spiClass,
                                           Properties factorySettings)
                                    throws JMSException

Throws:

JMSException

setProviderMetaData

protected void setProviderMetaData(ConnectionMetaData metaData,
                                   JmsClientProperties props)
                            throws JMSException

Throws:

JMSException

runJmsClient

protected abstract void runJmsClient(String clientName,
                                     int clientDestIndex,
                                     int clientDestCount)

parseStringArgs

protected static Properties parseStringArgs(String[] args)