public class MessageDispatch extends BaseCommand
Modifier and Type | Field and Description |
---|---|
protected java.lang.Object |
consumer |
protected ConsumerId |
consumerId |
static byte |
DATA_STRUCTURE_TYPE |
protected long |
deliverySequenceId |
protected ActiveMQDestination |
destination |
protected Message |
message |
protected int |
redeliveryCounter |
protected java.lang.Throwable |
rollbackCause |
protected java.lang.Runnable |
transmitCallback |
commandId, responseRequired
Constructor and Description |
---|
MessageDispatch() |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
getConsumer() |
ConsumerId |
getConsumerId() |
byte |
getDataStructureType() |
long |
getDeliverySequenceId() |
ActiveMQDestination |
getDestination() |
Message |
getMessage() |
int |
getRedeliveryCounter() |
java.lang.Throwable |
getRollbackCause() |
java.lang.Runnable |
getTransmitCallback() |
boolean |
isMessageDispatch() |
void |
setConsumer(java.lang.Object consumer) |
void |
setConsumerId(ConsumerId consumerId) |
void |
setDeliverySequenceId(long deliverySequenceId) |
void |
setDestination(ActiveMQDestination destination) |
void |
setMessage(Message message) |
void |
setRedeliveryCounter(int deliveryCounter) |
void |
setRollbackCause(java.lang.Throwable rollbackCause) |
void |
setTransmitCallback(java.lang.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 java.lang.Object consumer
protected transient java.lang.Runnable transmitCallback
protected transient java.lang.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 java.lang.Object getConsumer()
public void setConsumer(java.lang.Object consumer)
public Response visit(CommandVisitor visitor) throws java.lang.Exception
java.lang.Exception
public java.lang.Runnable getTransmitCallback()
public void setTransmitCallback(java.lang.Runnable transmitCallback)
public java.lang.Throwable getRollbackCause()
public void setRollbackCause(java.lang.Throwable rollbackCause)
Copyright © 2005-2012. All Rights Reserved.