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() |
org.fusesource.hawtbuf.UTF8Buffer |
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
|
long |
getTimeout() |
void |
setConsumerId(ConsumerId consumerId) |
void |
setCorrelationId(org.fusesource.hawtbuf.UTF8Buffer correlationId) |
void |
setDestination(ActiveMQDestination destination) |
void |
setMessageId(MessageId messageId) |
void |
setTimeout(long timeout) |
copy, getCommandId, isBrokerInfo, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setResponseRequired, toString, toString
public static final byte DATA_STRUCTURE_TYPE
protected ConsumerId consumerId
protected ActiveMQDestination destination
protected long timeout
public byte getDataStructureType()
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 org.fusesource.hawtbuf.UTF8Buffer getCorrelationId()
public void setCorrelationId(org.fusesource.hawtbuf.UTF8Buffer correlationId)
public MessageId getMessageId()
public void setMessageId(MessageId messageId)
Copyright © 2011-2014 Red Hat. All Rights Reserved.