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:
javax.jms.MessageListener

public class Consumer
extends BenchmarkSupport
implements javax.jms.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(java.lang.String[] args)
           
 void onMessage(javax.jms.Message message)
           
 void run()
           
protected  void subscribe()
           
protected  void subscribe(java.lang.String subject)
           
 
Methods inherited from class org.apache.activemq.benchmark.BenchmarkSupport
addResource, asMemoryString, count, createDestination, createFactory, createSession, getConnectionCount, getFactory, getUrl, isDurable, isTopic, parseBoolean, resetCount, setConnectionCount, setDurable, 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
 

Constructor Detail

Consumer

public Consumer()
Method Detail

main

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

run

public void run()
         throws javax.jms.JMSException
Throws:
javax.jms.JMSException

subscribe

protected void subscribe()
                  throws javax.jms.JMSException
Throws:
javax.jms.JMSException

subscribe

protected void subscribe(java.lang.String subject)
                  throws javax.jms.JMSException
Throws:
javax.jms.JMSException

onMessage

public void onMessage(javax.jms.Message message)
Specified by:
onMessage in interface javax.jms.MessageListener


Copyright © 2009 Apache Software Foundation. All Rights Reserved.