Package org.apache.activemq.command
Class MessageDispatch
- java.lang.Object
-
- org.apache.activemq.command.BaseCommand
-
- org.apache.activemq.command.MessageDispatch
-
- All Implemented Interfaces:
Command
,DataStructure
public class MessageDispatch extends BaseCommand
-
-
Field Summary
Fields Modifier and Type Field 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
-
Fields inherited from class org.apache.activemq.command.BaseCommand
commandId, responseRequired
-
-
Constructor Summary
Constructors Constructor Description MessageDispatch()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
Methods inherited from class org.apache.activemq.command.BaseCommand
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isConsumerControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, toString
-
-
-
-
Field Detail
-
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
-
consumerId
protected ConsumerId consumerId
-
destination
protected ActiveMQDestination destination
-
message
protected Message message
-
redeliveryCounter
protected int redeliveryCounter
-
deliverySequenceId
protected transient long deliverySequenceId
-
consumer
protected transient Object consumer
-
transmitCallback
protected transient TransmitCallback transmitCallback
-
rollbackCause
protected transient Throwable rollbackCause
-
-
Method Detail
-
getDataStructureType
public byte getDataStructureType()
- Returns:
- The type of the data structure
-
isMessageDispatch
public boolean isMessageDispatch()
- Specified by:
isMessageDispatch
in interfaceCommand
- Overrides:
isMessageDispatch
in classBaseCommand
-
getConsumerId
public ConsumerId getConsumerId()
-
setConsumerId
public void setConsumerId(ConsumerId consumerId)
-
getDestination
public ActiveMQDestination getDestination()
-
setDestination
public void setDestination(ActiveMQDestination destination)
-
getMessage
public Message getMessage()
-
setMessage
public void setMessage(Message message)
-
getDeliverySequenceId
public long getDeliverySequenceId()
-
setDeliverySequenceId
public void setDeliverySequenceId(long deliverySequenceId)
-
getRedeliveryCounter
public int getRedeliveryCounter()
-
setRedeliveryCounter
public void setRedeliveryCounter(int deliveryCounter)
-
getConsumer
public Object getConsumer()
-
setConsumer
public void setConsumer(Object consumer)
-
visit
public Response visit(CommandVisitor visitor) throws Exception
- Throws:
Exception
-
getTransmitCallback
public TransmitCallback getTransmitCallback()
-
setTransmitCallback
public void setTransmitCallback(TransmitCallback transmitCallback)
-
getRollbackCause
public Throwable getRollbackCause()
-
setRollbackCause
public void setRollbackCause(Throwable rollbackCause)
-
-