Package org.apache.activemq.tool
Class JMSMemtest
- java.lang.Object
-
- org.apache.activemq.tool.JMSMemtest
-
public class JMSMemtest extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected booleanallMessagesConsumedprotected MemConsumerallMessagesListprotected BrokerServicebrokerprotected intcheckpointIntervalprotected Connectionconnectionprotected intconnectionCheckpointSizeprotected ActiveMQConnectionFactoryconnectionFactoryprotected longconnectionIntervalprotected intconsumerCountprotected MemConsumer[]consumersprotected booleancreateConnectionPerClientprotected Destinationdestinationprotected StringdestinationNameprotected booleandurableprotected MemoryMonitoringToolmemoryMonitoringToolprotected longmessageCountprotected intmessageSizeprotected Messagepayloadprotected intprefetchSizeprotected intproducerCountprotected MemProducer[]producersprotected StringreportDirectoryprotected StringreportNameprotected booleantopicprotected booleantransactedprotected Stringurlprotected booleanuseEmbeddedBroker
-
Constructor Summary
Constructors Constructor Description JMSMemtest(Properties settings)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidclose()protected voidcloseConsumers()protected voidcloseProducers()protected voidconfigureBroker(BrokerService broker)protected BrokerServicecreateBroker()protected ConnectionFactorycreateConnectionFactory()protected voidcreateConsumers()protected voidcreatePayload(Session session)protected voidcreateProducers()protected PropertiesgetSysTestSettings()static voidmain(String[] args)protected voidpublishAndConsume()protected booleanresetConnection(int counter)protected voidstart()
-
-
-
Field Detail
-
broker
protected BrokerService broker
-
topic
protected boolean topic
-
durable
protected boolean durable
-
messageCount
protected long messageCount
-
connectionCheckpointSize
protected int connectionCheckpointSize
-
connectionInterval
protected long connectionInterval
-
consumerCount
protected int consumerCount
-
producerCount
protected int producerCount
-
checkpointInterval
protected int checkpointInterval
-
prefetchSize
protected int prefetchSize
-
messageSize
protected int messageSize
-
reportDirectory
protected String reportDirectory
-
reportName
protected String reportName
-
url
protected String url
-
producers
protected MemProducer[] producers
-
consumers
protected MemConsumer[] consumers
-
destinationName
protected String destinationName
-
allMessagesConsumed
protected boolean allMessagesConsumed
-
allMessagesList
protected MemConsumer allMessagesList
-
payload
protected Message payload
-
connectionFactory
protected ActiveMQConnectionFactory connectionFactory
-
connection
protected Connection connection
-
destination
protected Destination destination
-
createConnectionPerClient
protected boolean createConnectionPerClient
-
transacted
protected boolean transacted
-
useEmbeddedBroker
protected boolean useEmbeddedBroker
-
memoryMonitoringTool
protected MemoryMonitoringTool memoryMonitoringTool
-
-
Constructor Detail
-
JMSMemtest
public JMSMemtest(Properties settings)
-
-
Method Detail
-
main
public static void main(String[] args)
-
resetConnection
protected boolean resetConnection(int counter)
-
createPayload
protected void createPayload(Session session) throws JMSException
- Throws:
JMSException
-
createProducers
protected void createProducers() throws JMSException- Throws:
JMSException
-
createConsumers
protected void createConsumers() throws JMSException- Throws:
JMSException
-
closeProducers
protected void closeProducers() throws JMSException- Throws:
JMSException
-
closeConsumers
protected void closeConsumers() throws JMSException- Throws:
JMSException
-
createConnectionFactory
protected ConnectionFactory createConnectionFactory() throws JMSException
- Throws:
JMSException
-
createBroker
protected BrokerService createBroker() throws Exception
- Throws:
Exception
-
configureBroker
protected void configureBroker(BrokerService broker) throws Exception
- Throws:
Exception
-
getSysTestSettings
protected Properties getSysTestSettings()
-
-