org.apache.activemq.tool
Class AbstractJmsClientSystem

java.lang.Object
  extended by org.apache.activemq.tool.properties.AbstractObjectProperties
      extended by org.apache.activemq.tool.AbstractJmsClientSystem
All Implemented Interfaces:
ReflectionConfigurable
Direct Known Subclasses:
JmsConsumerSystem, JmsProducerSystem

public abstract class AbstractJmsClientSystem
extends AbstractObjectProperties


Field Summary
protected  ThreadGroup clientThreadGroup
           
protected  CpuSamplerTask cpuSampler
           
protected  JmsFactoryProperties factory
           
protected  ConnectionFactory jmsConnFactory
           
protected  ThroughputSamplerTask tpSampler
           
 
Constructor Summary
AbstractJmsClientSystem()
           
 
Method Summary
protected  PerformanceReportWriter createPerfWriter()
           
protected  void distributeDestinations(String distroType, int clientIndex, int numClients, int numDests)
           
 CpuSamplerTask getCpuSampler()
           
 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 setCpuSampler(CpuSamplerTask cpuSampler)
           
 void setFactory(JmsFactoryProperties factory)
           
protected  void setProviderMetaData(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 ThreadGroup clientThreadGroup

jmsConnFactory

protected 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 JMSException
Throws:
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(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)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.