Class RedeliveryQueueImpl.RedeliverCandidate

    • Constructor Detail

      • RedeliverCandidate

        protected RedeliverCandidate​(org.apache.cxf.message.Message m)
    • Method Detail

      • initiate

        protected void initiate()
        Initiate redelivery asynchronsly.
      • run

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

        public long getNumber()
      • getNext

        public Date getNext()
        Specified by:
        getNext in interface RetryStatus
        Returns:
        the next retry time
      • getRetries

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

        public int getMaxRetries()
        Specified by:
        getMaxRetries in interface RetryStatus
        Returns:
        the max number of retries permitted
      • 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
      • isPending

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

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

        protected void resolved()
        the message has been delivered to the application
      • cancel

        protected void cancel()
        Cancel further redelivery (although not successfully delivered).
      • 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()