Field Detail

• DEFAULT_BASE_RETRANSMISSION_INTERVAL

  static final String DEFAULT_BASE_RETRANSMISSION_INTERVAL

  See Also:

  Constant Field Values

• DEFAULT_EXPONENTIAL_BACKOFF

  static final int DEFAULT_EXPONENTIAL_BACKOFF

  See Also:

  Constant Field Values

Method Detail

• countUnacknowledged

  int countUnacknowledged(SourceSequence seq)

  Parameters:

  seq - the sequence under consideration

  Returns:

  the number of unacknowledged messages for that sequence

• countUnacknowledged

  int countUnacknowledged()

  Returns:

  the total number of unacknowledged messages in this queue

• isEmpty

  boolean isEmpty()

  Returns:

  true if there are no unacknowledged messages in the queue

• addUnacknowledged

  void addUnacknowledged(Message message)

  Accepts a new message for possible future retransmission. Implementations must call the RMEndpoint.handleAccepted() method for each accepted message.

  Parameters:

  message - the message context.

• purgeAcknowledged

  void purgeAcknowledged(SourceSequence seq)

  Purge all candidates for the given sequence that have been acknowledged. Implementations must call the RMEndpoint.handleAcknowledgment() method for each acknowledged message.

  Parameters:

  seq - the sequence object.

• purgeAll

  void purgeAll(SourceSequence seq)

  Purge all candidates for the given sequence.

  Parameters:

  seq - the sequence object

• getUnacknowledgedMessageNumbers

  List<Long> getUnacknowledgedMessageNumbers(SourceSequence seq)

  Parameters:

  seq -

  Returns:

• getRetransmissionStatus

  RetryStatus getRetransmissionStatus(SourceSequence seq,
                                    long num)

  Returns the retransmission status for the specified message.

  Parameters:

  seq -

  num -

  Returns:

• getRetransmissionStatuses

  Map<Long,RetryStatus> getRetransmissionStatuses(SourceSequence seq)

  Return the retransmission status of all the messages assigned to the sequence.

  Parameters:

  seq -

  Returns:

• start

  void start()

  Initiate resends.

• stop

  void stop(SourceSequence seq)

  Stops retransmission queue.

  Parameters:

  seq -

• suspend

  void suspend(SourceSequence seq)

  Suspends the retransmission attempts for the specified sequence

  Parameters:

  seq -

• resume

  void resume(SourceSequence seq)

  Resumes the retransmission attempts for the specified sequence

  Parameters:

  seq -