org.apache.activemq.command
Class MessagePull
java.lang.Object
org.apache.activemq.command.BaseCommand
org.apache.activemq.command.MessagePull
- All Implemented Interfaces:
- Command, DataStructure
public class MessagePull
- extends BaseCommand
Used to pull messages on demand.
- Version:
- $Revision: 430476 $
Methods inherited from class org.apache.activemq.command.BaseCommand |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
consumerId
protected ConsumerId consumerId
destination
protected ActiveMQDestination destination
timeout
protected long timeout
MessagePull
public MessagePull()
getDataStructureType
public byte getDataStructureType()
- Returns:
- The type of the data structure
visit
public Response visit(CommandVisitor visitor)
throws java.lang.Exception
- Throws:
java.lang.Exception
configure
public void configure(ConsumerInfo info)
- Configures a message pull from the consumer information
getConsumerId
public ConsumerId getConsumerId()
setConsumerId
public void setConsumerId(ConsumerId consumerId)
getDestination
public ActiveMQDestination getDestination()
setDestination
public void setDestination(ActiveMQDestination destination)
getTimeout
public long getTimeout()
setTimeout
public void setTimeout(long timeout)
Copyright © 2010 Apache Software Foundation. All Rights Reserved.