org.apache.activemq.tool
Class MemConsumer
java.lang.Object
org.apache.activemq.tool.MemMessageIdList
org.apache.activemq.tool.MemConsumer
- All Implemented Interfaces:
- MessageListener
public class MemConsumer
- extends MemMessageIdList
- implements MessageListener
- Version:
- $Revision: 1.3 $
Methods inherited from class org.apache.activemq.tool.MemMessageIdList |
equals, flushMessages, getMessageCount, getMessageIds, getParent, hashCode, hasReceivedMessage, hasReceivedMessages, isVerbose, setParent, setVerbose, toString, waitForMessagesToArrive |
connection
protected Connection connection
consumer
protected MessageConsumer consumer
counter
protected long counter
isParent
protected boolean isParent
inOrder
protected boolean inOrder
MemConsumer
public MemConsumer()
MemConsumer
public MemConsumer(ConnectionFactory fac,
Destination dest,
String consumerName)
throws JMSException
- Throws:
JMSException
MemConsumer
public MemConsumer(ConnectionFactory fac,
Destination dest)
throws JMSException
- Throws:
JMSException
start
public void start()
throws JMSException
- Throws:
JMSException
stop
public void stop()
throws JMSException
- Throws:
JMSException
shutDown
public void shutDown()
throws JMSException
- Throws:
JMSException
receive
public Message receive()
throws JMSException
- Throws:
JMSException
receive
public Message receive(long wait)
throws JMSException
- Throws:
JMSException
onMessage
public void onMessage(Message msg)
- Specified by:
onMessage
in interface MessageListener
- Overrides:
onMessage
in class MemMessageIdList
isInOrder
public boolean isInOrder()
setAsParent
public void setAsParent(boolean isParent)
isParent
public boolean isParent()
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.