org.activemq.benchmark
Class Consumer
java.lang.Object
org.activemq.benchmark.BenchmarkSupport
org.activemq.benchmark.Consumer
- All Implemented Interfaces:
- MessageListener
public class Consumer
- extends BenchmarkSupport
- implements MessageListener
- Version:
- $Revision$
- Author:
- James Strachan
Methods inherited from class org.activemq.benchmark.BenchmarkSupport |
addResource, asMemoryString, count, createDestination, createFactory, createSession, getConnectionCount, getFactory, getUrl, isDurable, isEmbeddedBroker, isTopic, parseBoolean, resetCount, setConnectionCount, setDurable, setEmbeddedBroker, setFactory, setSubject, setTopic, setUrl, start, timerLoop, useTimerLoop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Consumer
public Consumer()
main
public static void main(String[] args)
run
public void run()
throws JMSException
- Throws:
JMSException
subscribe
protected void subscribe()
throws JMSException
- Throws:
JMSException
subscribe
protected void subscribe(String subject)
throws JMSException
- Throws:
JMSException
onMessage
public void onMessage(Message message)
- Specified by:
onMessage
in interface MessageListener
Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.