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 TransmitCallback |
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() |
TransmitCallback |
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(TransmitCallback transmitCallback) |
Response |
visit(CommandVisitor visitor) |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isConsumerControl, 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 TransmitCallback 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 TransmitCallback getTransmitCallback()
public void setTransmitCallback(TransmitCallback transmitCallback)
public Throwable getRollbackCause()
public void setRollbackCause(Throwable rollbackCause)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.