Interface RedeliveryQueue

    • Method Detail

      • countUndelivered

        int countUndelivered​(DestinationSequence seq)
        Parameters:
        seq - the sequence under consideration
        Returns:
        the number of unacknowledged messages for that sequence
      • countUndelivered

        int countUndelivered()
        Returns:
        the total number of undelivered messages in this queue
      • isEmpty

        boolean isEmpty()
        Returns:
        true if there are no unacknowledged messages in the queue
      • addUndelivered

        void addUndelivered​(org.apache.cxf.message.Message message)
        Accepts a failed message for possible future redelivery.
        Parameters:
        message - the message context.
      • purgeAll

        void purgeAll​(DestinationSequence seq)
        Purge all candiates for the given sequence.
        Parameters:
        seq - the sequence object
      • getRedeliveryStatus

        RetryStatus getRedeliveryStatus​(DestinationSequence seq,
                                        long num)
        Returns the retransmission status for the specified message.
        Parameters:
        seq -
        num -
        Returns:
      • getRedeliveryStatuses

        Map<Long,​RetryStatus> getRedeliveryStatuses​(DestinationSequence seq)
        Return the retransmission status of all the messages assigned to the sequence.
        Parameters:
        seq -
        Returns:
      • start

        void start()
        Initiate resends.
      • suspend

        void suspend​(DestinationSequence seq)
        Suspends the redelivery attempts for the specified sequence
        Parameters:
        seq -
      • resume

        void resume​(DestinationSequence seq)
        Resumes the redelivery attempts for the specified sequence
        Parameters:
        seq -