Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ tool overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.tool
Class ConsumerTool  

java.lang.Object
  org.activemq.tool.ToolSupport
      org.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
private  boolean	pauseBeforeShutdown
protected  boolean	verbose

 

Fields inherited from class org.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(java.lang.String[] args)
void	onMessage(javax.jms.Message message)
void	run()

 

Methods inherited from class org.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

---

pauseBeforeShutdown

private boolean pauseBeforeShutdown

Constructor Detail

ConsumerTool

public ConsumerTool()

Method Detail

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

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ tool overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---