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 and Description
protected java.lang.ThreadGroup	clientThreadGroup
protected CpuSamplerTask	cpuSampler
protected JmsFactoryProperties	factory
protected javax.jms.ConnectionFactory	jmsConnFactory
protected ThroughputSamplerTask	tpSampler

Constructor Summary

Constructors

Constructor and Description
AbstractJmsClientSystem()

Method Summary

Methods

Modifier and Type	Method and Description
protected PerformanceReportWriter	createPerfWriter()
protected void	distributeDestinations(java.lang.String distroType, int clientIndex, int numClients, int numDests)
CpuSamplerTask	getCpuSampler()
JmsFactoryProperties	getFactory()
abstract JmsClientProperties	getJmsClientProperties()
abstract JmsClientSystemProperties	getSysTest()
ThroughputSamplerTask	getTpSampler()
protected javax.jms.ConnectionFactory	loadJmsFactory(java.lang.String spiClass, java.util.Properties factorySettings)
protected static java.util.Properties	parseStringArgs(java.lang.String[] args)
protected abstract void	runJmsClient(java.lang.String clientName, int clientDestIndex, int clientDestCount)
void	runSystemTest()
void	setCpuSampler(CpuSamplerTask cpuSampler)
void	setFactory(JmsFactoryProperties factory)
protected void	setProviderMetaData(javax.jms.ConnectionMetaData metaData, JmsClientProperties props)
abstract void	setSysTest(JmsClientSystemProperties sysTestProps)
void	setTpSampler(ThroughputSamplerTask tpSampler)

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 java.lang.ThreadGroup clientThreadGroup

jmsConnFactory

protected javax.jms.ConnectionFactory jmsConnFactory

factory

protected JmsFactoryProperties factory

tpSampler

protected ThroughputSamplerTask tpSampler

cpuSampler

protected CpuSamplerTask cpuSampler

Constructor Detail

AbstractJmsClientSystem

public AbstractJmsClientSystem()

Method Detail

runSystemTest

public void runSystemTest()
                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getTpSampler

public ThroughputSamplerTask getTpSampler()

setTpSampler

public void setTpSampler(ThroughputSamplerTask tpSampler)

getCpuSampler

public CpuSamplerTask getCpuSampler()

setCpuSampler

public void setCpuSampler(CpuSamplerTask cpuSampler)

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(java.lang.String distroType,
                          int clientIndex,
                          int numClients,
                          int numDests)

loadJmsFactory

protected javax.jms.ConnectionFactory loadJmsFactory(java.lang.String spiClass,
                                         java.util.Properties factorySettings)
                                              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

setProviderMetaData

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

Throws:

javax.jms.JMSException

runJmsClient

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

parseStringArgs

protected static java.util.Properties parseStringArgs(java.lang.String[] args)