public class JMSMemtest extends Object
Modifier and Type | Field and Description |
---|---|
protected boolean |
allMessagesConsumed |
protected MemConsumer |
allMessagesList |
protected BrokerService |
broker |
protected int |
checkpointInterval |
protected javax.jms.Connection |
connection |
protected int |
connectionCheckpointSize |
protected ActiveMQConnectionFactory |
connectionFactory |
protected long |
connectionInterval |
protected int |
consumerCount |
protected MemConsumer[] |
consumers |
protected boolean |
createConnectionPerClient |
protected javax.jms.Destination |
destination |
protected String |
destinationName |
protected boolean |
durable |
protected MemoryMonitoringTool |
memoryMonitoringTool |
protected long |
messageCount |
protected int |
messageSize |
protected javax.jms.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 and Description |
---|
JMSMemtest(Properties settings) |
Modifier and Type | Method and Description |
---|---|
protected void |
close() |
protected void |
closeConsumers() |
protected void |
closeProducers() |
protected void |
configureBroker(BrokerService broker) |
protected BrokerService |
createBroker() |
protected javax.jms.ConnectionFactory |
createConnectionFactory() |
protected void |
createConsumers() |
protected void |
createPayload(javax.jms.Session session) |
protected void |
createProducers() |
protected Properties |
getSysTestSettings() |
static void |
main(String[] args) |
protected void |
publishAndConsume() |
protected boolean |
resetConnection(int counter) |
protected void |
start() |
protected BrokerService broker
protected boolean topic
protected boolean durable
protected long messageCount
protected int connectionCheckpointSize
protected long connectionInterval
protected int consumerCount
protected int producerCount
protected int checkpointInterval
protected int prefetchSize
protected int messageSize
protected String reportDirectory
protected String reportName
protected MemProducer[] producers
protected MemConsumer[] consumers
protected String destinationName
protected boolean allMessagesConsumed
protected MemConsumer allMessagesList
protected javax.jms.Message payload
protected ActiveMQConnectionFactory connectionFactory
protected javax.jms.Connection connection
protected javax.jms.Destination destination
protected boolean createConnectionPerClient
protected boolean transacted
protected boolean useEmbeddedBroker
protected MemoryMonitoringTool memoryMonitoringTool
public JMSMemtest(Properties settings)
protected boolean resetConnection(int counter)
protected void publishAndConsume() throws Exception
Exception
protected void createPayload(javax.jms.Session session) throws javax.jms.JMSException
javax.jms.JMSException
protected void createProducers() throws javax.jms.JMSException
javax.jms.JMSException
protected void createConsumers() throws javax.jms.JMSException
javax.jms.JMSException
protected void closeProducers() throws javax.jms.JMSException
javax.jms.JMSException
protected void closeConsumers() throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.ConnectionFactory createConnectionFactory() throws javax.jms.JMSException
javax.jms.JMSException
protected BrokerService createBroker() throws Exception
Exception
protected void configureBroker(BrokerService broker) throws Exception
Exception
protected Properties getSysTestSettings()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.