public class MessageDispatch extends BaseCommand
Modifier and Type | Field and Description |
---|---|
protected Object |
consumer |
protected ConsumerId |
consumerId |
static byte |
DATA_STRUCTURE_TYPE |
protected long |
deliverySequenceId |
protected ActiveMQDestination |
destination |
protected Message |
message |
protected int |
redeliveryCounter |
protected Throwable |
rollbackCause |
protected Runnable |
transmitCallback |
commandId, responseRequired
Constructor and Description |
---|
MessageDispatch() |
Modifier and Type | Method and Description |
---|---|
Object |
getConsumer() |
ConsumerId |
getConsumerId() |
byte |
getDataStructureType() |
long |
getDeliverySequenceId() |
ActiveMQDestination |
getDestination() |
Message |
getMessage() |
int |
getRedeliveryCounter() |
Throwable |
getRollbackCause() |
Runnable |
getTransmitCallback() |
boolean |
isMessageDispatch() |
void |
setConsumer(Object consumer) |
void |
setConsumerId(ConsumerId consumerId) |
void |
setDeliverySequenceId(long deliverySequenceId) |
void |
setDestination(ActiveMQDestination destination) |
void |
setMessage(Message message) |
void |
setRedeliveryCounter(int deliveryCounter) |
void |
setRollbackCause(Throwable rollbackCause) |
void |
setTransmitCallback(Runnable transmitCallback) |
Response |
visit(CommandVisitor visitor) |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isMarshallAware, isMessage, isMessageAck, 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 int redeliveryCounter
protected transient long deliverySequenceId
protected transient Runnable transmitCallback
protected transient Throwable rollbackCause
public MessageDispatch()
public byte getDataStructureType()
public boolean isMessageDispatch()
isMessageDispatch
in interface Command
isMessageDispatch
in class BaseCommand
public ConsumerId getConsumerId()
public void setConsumerId(ConsumerId consumerId)
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
public Message getMessage()
public void setMessage(Message message)
public long getDeliverySequenceId()
public void setDeliverySequenceId(long deliverySequenceId)
public int getRedeliveryCounter()
public void setRedeliveryCounter(int deliveryCounter)
public Object getConsumer()
public void setConsumer(Object consumer)
public Response visit(CommandVisitor visitor) throws Exception
Exception
public Runnable getTransmitCallback()
public void setTransmitCallback(Runnable transmitCallback)
public Throwable getRollbackCause()
public void setRollbackCause(Throwable rollbackCause)
Copyright © 2005–2014. All rights reserved.