public class MessagePull extends BaseCommand
Modifier and Type | Field and Description |
---|---|
protected ConsumerId |
consumerId |
static byte |
DATA_STRUCTURE_TYPE |
protected ActiveMQDestination |
destination |
protected long |
timeout |
commandId, responseRequired
Constructor and Description |
---|
MessagePull() |
Modifier and Type | Method and Description |
---|---|
void |
configure(ConsumerInfo info)
Configures a message pull from the consumer information
|
ConsumerId |
getConsumerId() |
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
|
byte |
getDataStructureType() |
ActiveMQDestination |
getDestination() |
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
|
int |
getQuantity() |
long |
getTimeout() |
boolean |
isAlwaysSignalDone() |
boolean |
isTracked() |
void |
setAlwaysSignalDone(boolean alwaysSignalDone) |
void |
setConsumerId(ConsumerId consumerId) |
void |
setCorrelationId(String correlationId) |
void |
setDestination(ActiveMQDestination destination) |
void |
setMessageId(MessageId messageId) |
void |
setQuantity(int quantity) |
void |
setTimeout(long timeout) |
void |
setTracked(boolean tracked) |
Response |
visit(CommandVisitor visitor) |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isConsumerControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, toString
public static final byte DATA_STRUCTURE_TYPE
protected ConsumerId consumerId
protected ActiveMQDestination destination
protected long timeout
public MessagePull()
public byte getDataStructureType()
public Response visit(CommandVisitor visitor) throws Exception
Exception
public void configure(ConsumerInfo info)
public ConsumerId getConsumerId()
public void setConsumerId(ConsumerId consumerId)
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
public long getTimeout()
public void setTimeout(long timeout)
public String getCorrelationId()
public void setCorrelationId(String correlationId)
public MessageId getMessageId()
public void setMessageId(MessageId messageId)
public void setTracked(boolean tracked)
public boolean isTracked()
public int getQuantity()
public void setQuantity(int quantity)
public boolean isAlwaysSignalDone()
public void setAlwaysSignalDone(boolean alwaysSignalDone)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.