Class RetransmissionQueueImpl.ResendCandidate

    • Constructor Detail

      • ResendCandidate

        protected ResendCandidate​(org.apache.cxf.message.Message m)
        Parameters:
        m - the unacked message
    • Method Detail

      • initiate

        protected void initiate​(boolean requestAcknowledge)
        Initiate resend asynchronsly.
        Parameters:
        requestAcknowledge - true if a AckRequest header is to be sent with resend
      • run

        public void run()
        Specified by:
        run in interface Runnable
      • getNumber

        public long getNumber()
      • getRetries

        public int getRetries()
        Specified by:
        getRetries in interface RetryStatus
        Returns:
        number of resend attempts
      • getMaxRetries

        public int getMaxRetries()
        Specified by:
        getMaxRetries in interface RetryStatus
        Returns:
        number of max resend attempts
      • getNext

        public Date getNext()
        Specified by:
        getNext in interface RetryStatus
        Returns:
        date of next resend
      • getPrevious

        public Date getPrevious()
        Specified by:
        getPrevious in interface RetryStatus
        Returns:
        date of previous resend or null if no attempt is yet taken
      • getNextInterval

        public long getNextInterval()
        Specified by:
        getNextInterval in interface RetryStatus
        Returns:
        the nextInterval
      • getBackoff

        public long getBackoff()
        Specified by:
        getBackoff in interface RetryStatus
        Returns:
        the backoff
      • isSuspended

        public boolean isSuspended()
        Specified by:
        isSuspended in interface RetryStatus
        Returns:
        the suspended
      • isPending

        public boolean isPending()
        Specified by:
        isPending in interface RetryStatus
        Returns:
        if resend attempt is pending
      • resolved

        protected void resolved()
        ACK has been received for this candidate.
      • cancel

        protected void cancel()
        Cancel further resend (although no ACK has been received).
      • suspend

        protected void suspend()
      • resume

        protected void resume()
      • getMessage

        protected org.apache.cxf.message.Message getMessage()
        Returns:
        associated message context
      • attempted

        protected void attempted()
        A resend has been attempted. Schedule the next attempt.
      • schedule

        protected final void schedule()