org.apache.activemq.command
Class MessageDispatch

java.lang.Object
  extended by org.apache.activemq.command.BaseCommand
      extended by org.apache.activemq.command.MessageDispatch
All Implemented Interfaces:
Command, DataStructure

public class MessageDispatch
extends BaseCommand


Field Summary
protected  java.lang.Object consumer
           
protected  ConsumerId consumerId
           
static byte DATA_STRUCTURE_TYPE
           
protected  long deliverySequenceId
           
protected  ActiveMQDestination destination
           
protected  Message message
           
protected  int redeliveryCounter
           
protected  java.lang.Throwable rollbackCause
           
protected  java.lang.Runnable transmitCallback
           
 
Fields inherited from class org.apache.activemq.command.BaseCommand
commandId, responseRequired
 
Constructor Summary
MessageDispatch()
           
 
Method Summary
 java.lang.Object getConsumer()
           
 ConsumerId getConsumerId()
           
 byte getDataStructureType()
           
 long getDeliverySequenceId()
           
 ActiveMQDestination getDestination()
           
 Message getMessage()
           
 int getRedeliveryCounter()
           
 java.lang.Throwable getRollbackCause()
           
 java.lang.Runnable getTransmitCallback()
           
 boolean isMessageDispatch()
           
 void setConsumer(java.lang.Object consumer)
           
 void setConsumerId(ConsumerId consumerId)
           
 void setDeliverySequenceId(long deliverySequenceId)
           
 void setDestination(ActiveMQDestination destination)
           
 void setMessage(Message message)
           
 void setRedeliveryCounter(int deliveryCounter)
           
 void setRollbackCause(java.lang.Throwable rollbackCause)
           
 void setTransmitCallback(java.lang.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 java.lang.Object consumer

transmitCallback

protected transient java.lang.Runnable transmitCallback

rollbackCause

protected transient java.lang.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 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-2011 FuseSource, Corp.. All Rights Reserved.