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 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
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(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()
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.