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 Objectconsumerprotected ConsumerIdconsumerIdstatic byteDATA_STRUCTURE_TYPEprotected longdeliverySequenceIdprotected ActiveMQDestinationdestinationprotected Messagemessageprotected intredeliveryCounterprotected ThrowablerollbackCauseprotected TransmitCallbacktransmitCallback-
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 ObjectgetConsumer()ConsumerIdgetConsumerId()bytegetDataStructureType()longgetDeliverySequenceId()ActiveMQDestinationgetDestination()MessagegetMessage()intgetRedeliveryCounter()ThrowablegetRollbackCause()TransmitCallbackgetTransmitCallback()booleanisMessageDispatch()voidsetConsumer(Object consumer)voidsetConsumerId(ConsumerId consumerId)voidsetDeliverySequenceId(long deliverySequenceId)voidsetDestination(ActiveMQDestination destination)voidsetMessage(Message message)voidsetRedeliveryCounter(int deliveryCounter)voidsetRollbackCause(Throwable rollbackCause)voidsetTransmitCallback(TransmitCallback transmitCallback)Responsevisit(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:
isMessageDispatchin interfaceCommand- Overrides:
isMessageDispatchin 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)
-
-