Class DefaultRetryHandler

    • Field Detail

      • LOGGER

        private static final org.slf4j.Logger LOGGER
      • queueRecoveryRetryCondition

        protected final java.util.function.BiPredicate<? super RecordedQueue,​java.lang.Exception> queueRecoveryRetryCondition
      • exchangeRecoveryRetryCondition

        protected final java.util.function.BiPredicate<? super RecordedExchange,​java.lang.Exception> exchangeRecoveryRetryCondition
      • bindingRecoveryRetryCondition

        protected final java.util.function.BiPredicate<? super RecordedBinding,​java.lang.Exception> bindingRecoveryRetryCondition
      • consumerRecoveryRetryCondition

        protected final java.util.function.BiPredicate<? super RecordedConsumer,​java.lang.Exception> consumerRecoveryRetryCondition
      • retryAttempts

        protected final int retryAttempts
    • Method Detail

      • retryQueueRecovery

        public RetryResult retryQueueRecovery​(RetryContext context)
                                       throws java.lang.Exception
        Description copied from interface: RetryHandler
        Retry a failed queue recovery operation.
        Specified by:
        retryQueueRecovery in interface RetryHandler
        Parameters:
        context - the context of the retry
        Returns:
        the result of the retry attempt
        Throws:
        java.lang.Exception - if the retry fails
      • retryExchangeRecovery

        public RetryResult retryExchangeRecovery​(RetryContext context)
                                          throws java.lang.Exception
        Description copied from interface: RetryHandler
        Retry a failed exchange recovery operation.
        Specified by:
        retryExchangeRecovery in interface RetryHandler
        Parameters:
        context - the context of the retry
        Returns:
        the result of the retry attempt
        Throws:
        java.lang.Exception - if the retry fails
      • retryBindingRecovery

        public RetryResult retryBindingRecovery​(RetryContext context)
                                         throws java.lang.Exception
        Description copied from interface: RetryHandler
        Retry a failed binding recovery operation.
        Specified by:
        retryBindingRecovery in interface RetryHandler
        Parameters:
        context - the context of the retry
        Returns:
        the result of the retry attempt
        Throws:
        java.lang.Exception - if the retry fails
      • retryConsumerRecovery

        public RetryResult retryConsumerRecovery​(RetryContext context)
                                          throws java.lang.Exception
        Description copied from interface: RetryHandler
        Retry a failed consumer recovery operation.
        Specified by:
        retryConsumerRecovery in interface RetryHandler
        Parameters:
        context - the context of the retry
        Returns:
        the result of the retry attempt
        Throws:
        java.lang.Exception - if the retry fails
      • log

        protected void log​(RecordedEntity entity,
                           java.lang.Exception exception,
                           int attempts)