org.apache.activemq.tool
Class JMSMemtest

java.lang.Object
  extended by org.apache.activemq.tool.JMSMemtest

public class JMSMemtest
extends Object


Field Summary
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
JMSMemtest(Properties settings)
           
 
Method Summary
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()


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.