org.apache.activemq.tool
Class JMSMemtest
java.lang.Object
org.apache.activemq.tool.JMSMemtest
public class JMSMemtest
- extends java.lang.Object
Constructor Summary |
JMSMemtest(java.util.Properties settings)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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 java.lang.String reportDirectory
reportName
protected java.lang.String reportName
url
protected java.lang.String url
producers
protected MemProducer[] producers
consumers
protected MemConsumer[] consumers
destinationName
protected java.lang.String destinationName
allMessagesConsumed
protected boolean allMessagesConsumed
allMessagesList
protected MemConsumer allMessagesList
payload
protected javax.jms.Message payload
connectionFactory
protected ActiveMQConnectionFactory connectionFactory
connection
protected javax.jms.Connection connection
destination
protected javax.jms.Destination destination
createConnectionPerClient
protected boolean createConnectionPerClient
transacted
protected boolean transacted
useEmbeddedBroker
protected boolean useEmbeddedBroker
memoryMonitoringTool
protected MemoryMonitoringTool memoryMonitoringTool
JMSMemtest
public JMSMemtest(java.util.Properties settings)
main
public static void main(java.lang.String[] args)
start
protected void start()
throws java.lang.Exception
- Throws:
java.lang.Exception
resetConnection
protected boolean resetConnection(int counter)
publishAndConsume
protected void publishAndConsume()
throws java.lang.Exception
- Throws:
java.lang.Exception
close
protected void close()
throws java.lang.Exception
- Throws:
java.lang.Exception
createPayload
protected void createPayload(javax.jms.Session session)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createProducers
protected void createProducers()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createConsumers
protected void createConsumers()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
closeProducers
protected void closeProducers()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
closeConsumers
protected void closeConsumers()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createConnectionFactory
protected javax.jms.ConnectionFactory createConnectionFactory()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createBroker
protected BrokerService createBroker()
throws java.lang.Exception
- Throws:
java.lang.Exception
configureBroker
protected void configureBroker(BrokerService broker)
throws java.lang.Exception
- Throws:
java.lang.Exception
getSysTestSettings
protected java.util.Properties getSysTestSettings()
Copyright © 2011 Apache Software Foundation. All Rights Reserved.