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 and 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 and Description
JMSMemtest(Properties settings)

Method Summary

Methods

Modifier and Type	Method and 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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)

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()