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.
Methods inherited from class org.apache.activemq.command.BaseCommand |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, 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)
getCorrelationId
public java.lang.String getCorrelationId()
- An optional correlation ID which could be used by a broker to decide which messages are pulled
on demand from a queue for a consumer
setCorrelationId
public void setCorrelationId(java.lang.String correlationId)
getMessageId
public MessageId getMessageId()
- An optional message ID which could be used by a broker to decide which messages are pulled
on demand from a queue for a consumer
setMessageId
public void setMessageId(MessageId messageId)
Copyright © 2005-2016. All Rights Reserved.