org.apache.activemq.tool
Class ConsumerTool
java.lang.Object
org.apache.activemq.tool.ToolSupport
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$
Fields inherited from class org.apache.activemq.tool.ToolSupport |
ackMode, clientID, consumerName, destination, durable, pwd, subject, topic, transacted, url, user |
Method Summary |
protected void |
consumeMessagesAndClose(javax.jms.Connection connection,
javax.jms.Session session,
javax.jms.MessageConsumer consumer)
|
static void |
main(java.lang.String[] args)
|
void |
onMessage(javax.jms.Message message)
|
void |
run()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
count
protected int count
dumpCount
protected int dumpCount
verbose
protected boolean verbose
maxiumMessages
protected int maxiumMessages
ConsumerTool
public ConsumerTool()
main
public static void main(java.lang.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,
java.io.IOException
- Throws:
javax.jms.JMSException
java.io.IOException
Copyright © 2011 Apache Software Foundation. All Rights Reserved.