org.apache.activemq.tool
Class JMSMemtest
java.lang.Object
org.apache.activemq.tool.JMSMemtest
public class JMSMemtest
- extends Object
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 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 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(Properties settings)
main
public static void main(String[] args)
start
protected void start()
throws Exception
- Throws:
Exception
resetConnection
protected boolean resetConnection(int counter)
publishAndConsume
protected void publishAndConsume()
throws Exception
- Throws:
Exception
close
protected void close()
throws Exception
- Throws:
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 Exception
- Throws:
Exception
configureBroker
protected void configureBroker(BrokerService broker)
throws Exception
- Throws:
Exception
getSysTestSettings
protected Properties getSysTestSettings()
Copyright © 2011 Apache Software Foundation. All Rights Reserved.