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 boolean
allMessagesConsumed
protected MemConsumer
allMessagesList
protected BrokerService
broker
protected int
checkpointInterval
protected Connection
connection
protected int
connectionCheckpointSize
protected ActiveMQConnectionFactory
connectionFactory
protected long
connectionInterval
protected int
consumerCount
protected MemConsumer[]
consumers
protected boolean
createConnectionPerClient
protected Destination
destination
protected String
destinationName
protected boolean
durable
protected MemoryMonitoringTool
memoryMonitoringTool
protected long
messageCount
protected int
messageSize
protected Message
payload
protected int
prefetchSize
protected int
producerCount
protected MemProducer[]
producers
protected String
reportDirectory
protected String
reportName
protected boolean
topic
protected boolean
transacted
protected String
url
protected boolean
useEmbeddedBroker
-
Constructor Summary
Constructors Constructor Description JMSMemtest(Properties settings)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
close()
protected void
closeConsumers()
protected void
closeProducers()
protected void
configureBroker(BrokerService broker)
protected BrokerService
createBroker()
protected ConnectionFactory
createConnectionFactory()
protected void
createConsumers()
protected void
createPayload(Session session)
protected void
createProducers()
protected Properties
getSysTestSettings()
static void
main(String[] args)
protected void
publishAndConsume()
protected boolean
resetConnection(int counter)
protected void
start()
-
-
-
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()
-
-