java.lang.Object
org.activemq.benchmark.BenchmarkSupport
- Direct Known Subclasses:
- Consumer, Producer
- public class BenchmarkSupport
- extends java.lang.Object
Abstract base class for some simple benchmark tools
- Version:
- $Revision$
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
connectionCount
protected int connectionCount
batch
protected int batch
destination
protected javax.jms.Destination destination
embeddedBroker
protected boolean embeddedBroker
topic
private boolean topic
durable
private boolean durable
factory
private org.activemq.ActiveMQConnectionFactory factory
url
private java.lang.String url
subjects
protected java.lang.String[] subjects
time
private long time
counter
private int counter
resources
private java.util.List resources
formatter
private java.text.NumberFormat formatter
connectionCounter
private EDU.oswego.cs.dl.util.concurrent.SynchronizedInt connectionCounter
idGenerator
private org.activemq.util.IdGenerator idGenerator
BenchmarkSupport
public BenchmarkSupport()
start
public void start()
getUrl
public java.lang.String getUrl()
setUrl
public void setUrl(java.lang.String url)
isTopic
public boolean isTopic()
setTopic
public void setTopic(boolean topic)
getFactory
public org.activemq.ActiveMQConnectionFactory getFactory()
setFactory
public void setFactory(org.activemq.ActiveMQConnectionFactory factory)
setSubject
public void setSubject(java.lang.String subject)
isDurable
public boolean isDurable()
setDurable
public void setDurable(boolean durable)
isEmbeddedBroker
public boolean isEmbeddedBroker()
setEmbeddedBroker
public void setEmbeddedBroker(boolean embeddedBroker)
getConnectionCount
public int getConnectionCount()
setConnectionCount
public void setConnectionCount(int connectionCount)
createSession
protected javax.jms.Session createSession()
throws javax.jms.JMSException
createFactory
protected org.activemq.ActiveMQConnectionFactory createFactory()
count
protected void count(int count)
resetCount
protected int resetCount()
timerLoop
protected void timerLoop()
asMemoryString
protected java.lang.String asMemoryString(long value)
useTimerLoop
protected boolean useTimerLoop()
createDestination
protected javax.jms.Destination createDestination(javax.jms.Session session,
java.lang.String subject)
throws javax.jms.JMSException
addResource
protected void addResource(java.lang.Object resource)
parseBoolean
protected static boolean parseBoolean(java.lang.String text)