Interface RetransmissionQueue

    • 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​(org.apache.cxf.message.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 -