Package org.apache.activemq.command
Class ReplayCommand
- java.lang.Object
-
- org.apache.activemq.command.BaseCommand
-
- 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
Fields Modifier and Type Field Description static byte
DATA_STRUCTURE_TYPE
-
Fields inherited from class org.apache.activemq.command.BaseCommand
commandId, responseRequired
-
-
Constructor Summary
Constructors Constructor Description ReplayCommand()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte
getDataStructureType()
int
getFirstAckNumber()
int
getFirstNakNumber()
Is used to specify the first sequence number to be replayedint
getLastAckNumber()
int
getLastNakNumber()
Is used to specify the last sequence number to be replayedString
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 cachevoid
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 cachevoid
setLastNakNumber(int lastNakNumber)
void
setProducerId(String producerId)
Is used to uniquely identify the producer of the sequenceString
toString()
Response
visit(CommandVisitor visitor)
-
Methods inherited from class org.apache.activemq.command.BaseCommand
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isConsumerControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString
-
-
-
-
Field Detail
-
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
-
-
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 classBaseCommand
-
-