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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
clientThreadGroup
protected java.lang.ThreadGroup clientThreadGroup
jmsConnFactory
protected javax.jms.ConnectionFactory jmsConnFactory
factory
protected JmsFactoryProperties factory
tpSampler
protected ThroughputSamplerTask tpSampler
cpuSampler
protected CpuSamplerTask cpuSampler
AbstractJmsClientSystem
public AbstractJmsClientSystem()
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)
Copyright © 2010 Apache Software Foundation. All Rights Reserved.