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 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 Runnable	transmitCallback

Fields inherited from class org.apache.activemq.command.BaseCommand

commandId, responseRequired

Constructor Summary

Constructors

Constructor and Description
MessageDispatch()

Method Summary

Methods

Modifier and Type	Method and Description
Object	getConsumer()
ConsumerId	getConsumerId()
byte	getDataStructureType()
long	getDeliverySequenceId()
ActiveMQDestination	getDestination()
Message	getMessage()
int	getRedeliveryCounter()
Throwable	getRollbackCause()
Runnable	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(Runnable transmitCallback)
Response	visit(CommandVisitor visitor)

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

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 Runnable transmitCallback

rollbackCause

protected transient Throwable rollbackCause

Constructor Detail

MessageDispatch

public MessageDispatch()

Method Detail

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 Object getConsumer()

setConsumer

public void setConsumer(Object consumer)

visit

public Response visit(CommandVisitor visitor)
               throws Exception

Throws:

Exception

getTransmitCallback

public Runnable getTransmitCallback()

setTransmitCallback

public void setTransmitCallback(Runnable transmitCallback)

getRollbackCause

public Throwable getRollbackCause()

setRollbackCause

public void setRollbackCause(Throwable rollbackCause)