org.apache.activemq.tool

Class JMSMemtest

java.lang.Object

org.apache.activemq.tool.JMSMemtest

public class JMSMemtest
extends java.lang.Object

Field Summary

Fields

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 java.lang.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 java.lang.String	reportDirectory
protected java.lang.String	reportName
protected boolean	topic
protected boolean	transacted
protected java.lang.String	url
protected boolean	useEmbeddedBroker

Constructor Summary

Constructors

Constructor and Description
JMSMemtest(java.util.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 javax.jms.ConnectionFactory	createConnectionFactory()
protected void	createConsumers()
protected void	createPayload(javax.jms.Session session)
protected void	createProducers()
protected java.util.Properties	getSysTestSettings()
static void	main(java.lang.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 java.lang.String reportDirectory

reportName

protected java.lang.String reportName

url

protected java.lang.String url

producers

protected MemProducer[] producers

consumers

protected MemConsumer[] consumers

destinationName

protected java.lang.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

Constructor Detail

JMSMemtest

public JMSMemtest(java.util.Properties settings)

Method Detail

main

public static void main(java.lang.String[] args)

start

protected void start()
              throws java.lang.Exception

Throws:

java.lang.Exception

resetConnection

protected boolean resetConnection(int counter)

publishAndConsume

protected void publishAndConsume()
                          throws java.lang.Exception

Throws:

java.lang.Exception

close

protected void close()
              throws java.lang.Exception

Throws:

java.lang.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 java.lang.Exception

Throws:

java.lang.Exception

configureBroker

protected void configureBroker(BrokerService broker)
                        throws java.lang.Exception

Throws:

java.lang.Exception

getSysTestSettings

protected java.util.Properties getSysTestSettings()