org.apache.activemq.tool
Class ConsumerTool

java.lang.Object
  extended by org.apache.activemq.tool.ToolSupport
      extended by org.apache.activemq.tool.ConsumerTool
All Implemented Interfaces:
javax.jms.MessageListener

public class ConsumerTool
extends ToolSupport
implements javax.jms.MessageListener

A simple tool for consuming messages

Version:
$Revision$

Field Summary
protected  int count
           
protected  int dumpCount
           
protected  int maxiumMessages
           
protected  boolean verbose
           
 
Fields inherited from class org.apache.activemq.tool.ToolSupport
ackMode, clientID, consumerName, destination, durable, pwd, subject, topic, transacted, url, user
 
Constructor Summary
ConsumerTool()
           
 
Method Summary
protected  void consumeMessagesAndClose(javax.jms.Connection connection, javax.jms.Session session, javax.jms.MessageConsumer consumer)
           
static void main(String[] args)
           
 void onMessage(javax.jms.Message message)
           
 void run()
           
 
Methods inherited from class org.apache.activemq.tool.ToolSupport
close, createConnection, createSession, dumpStats
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

count

protected int count

dumpCount

protected int dumpCount

verbose

protected boolean verbose

maxiumMessages

protected int maxiumMessages
Constructor Detail

ConsumerTool

public ConsumerTool()
Method Detail

main

public static void main(String[] args)

run

public void run()

onMessage

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

consumeMessagesAndClose

protected void consumeMessagesAndClose(javax.jms.Connection connection,
                                       javax.jms.Session session,
                                       javax.jms.MessageConsumer consumer)
                                throws javax.jms.JMSException,
                                       IOException
Throws:
javax.jms.JMSException
IOException


Copyright © 2011 Apache Software Foundation. All Rights Reserved.