org.apache.activemq.command
Class ReplayCommand

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

public class ReplayCommand
extends BaseCommand

A general purpose replay command for some kind of producer where ranges of messages are asked to be replayed. This command is typically used over a non-reliable transport such as UDP or multicast but could also be used on TCP/IP if a socket has been re-established.


Field Summary
static byte DATA_STRUCTURE_TYPE
           
 
Fields inherited from class org.apache.activemq.command.BaseCommand
commandId, responseRequired
 
Constructor Summary
ReplayCommand()
           
 
Method Summary
 byte getDataStructureType()
           
 int getFirstAckNumber()
           
 int getFirstNakNumber()
          Is used to specify the first sequence number to be replayed
 int getLastAckNumber()
           
 int getLastNakNumber()
          Is used to specify the last sequence number to be replayed
 String getProducerId()
           
 void setFirstAckNumber(int firstSequenceNumber)
          Is used to specify the first sequence number being acknowledged as delivered on the transport so that it can be removed from cache
 void setFirstNakNumber(int firstNakNumber)
           
 void setLastAckNumber(int lastSequenceNumber)
          Is used to specify the last sequence number being acknowledged as delivered on the transport so that it can be removed from cache
 void setLastNakNumber(int lastNakNumber)
           
 void setProducerId(String producerId)
          Is used to uniquely identify the producer of the sequence
 String toString()
           
 Response visit(CommandVisitor visitor)
           
 
Methods inherited from class org.apache.activemq.command.BaseCommand
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, 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
Constructor Detail

ReplayCommand

public ReplayCommand()
Method Detail

getDataStructureType

public byte getDataStructureType()
Returns:
The type of the data structure

getProducerId

public String getProducerId()

setProducerId

public void setProducerId(String producerId)
Is used to uniquely identify the producer of the sequence


getFirstAckNumber

public int getFirstAckNumber()

setFirstAckNumber

public void setFirstAckNumber(int firstSequenceNumber)
Is used to specify the first sequence number being acknowledged as delivered on the transport so that it can be removed from cache


getLastAckNumber

public int getLastAckNumber()

setLastAckNumber

public void setLastAckNumber(int lastSequenceNumber)
Is used to specify the last sequence number being acknowledged as delivered on the transport so that it can be removed from cache


visit

public Response visit(CommandVisitor visitor)
               throws Exception
Throws:
Exception

getFirstNakNumber

public int getFirstNakNumber()
Is used to specify the first sequence number to be replayed


setFirstNakNumber

public void setFirstNakNumber(int firstNakNumber)

getLastNakNumber

public int getLastNakNumber()
Is used to specify the last sequence number to be replayed


setLastNakNumber

public void setLastNakNumber(int lastNakNumber)

toString

public String toString()
Overrides:
toString in class BaseCommand


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.