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
Methods inherited from class org.apache.activemq.command.BaseCommand |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
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 java.lang.Object consumer
transmitCallback
protected transient java.lang.Runnable transmitCallback
rollbackCause
protected transient java.lang.Throwable rollbackCause
MessageDispatch
public MessageDispatch()
getDataStructureType
public byte getDataStructureType()
- Returns:
- The type of the data structure
isMessageDispatch
public boolean isMessageDispatch()
- Specified by:
isMessageDispatch
in interface Command
- Overrides:
isMessageDispatch
in class BaseCommand
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 java.lang.Object getConsumer()
setConsumer
public void setConsumer(java.lang.Object consumer)
visit
public Response visit(CommandVisitor visitor)
throws java.lang.Exception
- Throws:
java.lang.Exception
getTransmitCallback
public java.lang.Runnable getTransmitCallback()
setTransmitCallback
public void setTransmitCallback(java.lang.Runnable transmitCallback)
getRollbackCause
public java.lang.Throwable getRollbackCause()
setRollbackCause
public void setRollbackCause(java.lang.Throwable rollbackCause)
Copyright © 2005-2015. All Rights Reserved.