Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.perf
Class PerfConsumer  view PerfConsumer download PerfConsumer.java

java.lang.Object
  extended byorg.activemq.perf.PerfConsumer
All Implemented Interfaces:
javax.jms.MessageListener

public class PerfConsumer
extends java.lang.Object
implements javax.jms.MessageListener

Version:
$Revision: 1.3 $

Field Summary
protected  javax.jms.Connection connection
           
protected  javax.jms.MessageConsumer consumer
           
protected  PerfRate rate
           
 
Constructor Summary
PerfConsumer(javax.jms.ConnectionFactory fac, javax.jms.Destination dest)
           
PerfConsumer(javax.jms.ConnectionFactory fac, javax.jms.Destination dest, java.lang.String consumerName)
           
 
Method Summary
 PerfRate getRate()
           
 void onMessage(javax.jms.Message msg)
           
 void shutDown()
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

connection

protected javax.jms.Connection connection

consumer

protected javax.jms.MessageConsumer consumer

rate

protected PerfRate rate
Constructor Detail

PerfConsumer

public PerfConsumer(javax.jms.ConnectionFactory fac,
                    javax.jms.Destination dest,
                    java.lang.String consumerName)
             throws javax.jms.JMSException

PerfConsumer

public PerfConsumer(javax.jms.ConnectionFactory fac,
                    javax.jms.Destination dest)
             throws javax.jms.JMSException
Method Detail

start

public void start()
           throws javax.jms.JMSException

stop

public void stop()
          throws javax.jms.JMSException

shutDown

public void shutDown()
              throws javax.jms.JMSException

getRate

public PerfRate getRate()

onMessage

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