org.activemq.tool
Class ConsumerTool
java.lang.Object
org.activemq.tool.ToolSupport
org.activemq.tool.ConsumerTool
- All Implemented Interfaces:
- MessageListener
public class ConsumerTool
- extends ToolSupport
- implements MessageListener
A simple tool for consuming messages
- Version:
- $Revision$
Fields inherited from class org.activemq.tool.ToolSupport |
ackMode, clientID, consumerName, destination, durable, pwd, subject, topic, transacted, url, user |
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(String[] args)
run
public void run()
onMessage
public void onMessage(Message message)
- Specified by:
onMessage
in interface MessageListener
consumeMessagesAndClose
protected void consumeMessagesAndClose(Connection connection,
Session session,
MessageConsumer consumer)
throws JMSException,
IOException
- Throws:
JMSException
IOException
Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.