org.apache.activemq.benchmark
Class Consumer

java.lang.Object
  extended by org.apache.activemq.benchmark.BenchmarkSupport
      extended by org.apache.activemq.benchmark.Consumer
All Implemented Interfaces:
MessageListener

public class Consumer
extends BenchmarkSupport
implements MessageListener

Version:
$Revision$
Author:
James Strachan

Field Summary
 
Fields inherited from class org.apache.activemq.benchmark.BenchmarkSupport
batch, connectionCount, destination, subjects
 
Constructor Summary
Consumer()
           
 
Method Summary
static void main(String[] args)
           
 void onMessage(Message message)
           
 void run()
           
protected  void subscribe()
           
protected  void subscribe(String subject)
           
 
Methods inherited from class org.apache.activemq.benchmark.BenchmarkSupport
addResource, asMemoryString, count, createDestination, createFactory, createSession, getConnectionCount, getCounter, getFactory, getUrl, isDurable, isTopic, parseBoolean, resetCount, setConnectionCount, setDurable, setFactory, setSubject, setTimerLoop, setTopic, setUrl, start, timerLoop, useTimerLoop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Consumer

public Consumer()
Method Detail

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 © 2005-2011 Apache Software Foundation. All Rights Reserved.