Class 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.
    • 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
      • 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)