Class TopologyRecoveryRetryLogic

    • Field Detail

      • CHANNEL_CLOSED_NOT_FOUND

        public static final java.util.function.BiPredicate<RecordedEntity,​java.lang.Exception> CHANNEL_CLOSED_NOT_FOUND
        Channel has been closed because of a resource that doesn't exist.
      • RECOVER_PREVIOUS_QUEUE_BINDINGS

        public static final DefaultRetryHandler.RetryOperation<java.lang.Void> RECOVER_PREVIOUS_QUEUE_BINDINGS
        Recover earlier bindings that share the same queue as this retry context
      • RECOVER_CONSUMER_QUEUE_BINDINGS

        public static final DefaultRetryHandler.RetryOperation<java.lang.Void> RECOVER_CONSUMER_QUEUE_BINDINGS
        Recover all the bindings of the queue of a consumer.
      • RECOVER_PREVIOUS_CONSUMERS

        public static final DefaultRetryHandler.RetryOperation<java.lang.String> RECOVER_PREVIOUS_CONSUMERS
        Recover earlier consumers that share the same channel as this retry context
      • RECOVER_PREVIOUS_AUTO_DELETE_QUEUES

        public static final DefaultRetryHandler.RetryOperation<java.lang.Void> RECOVER_PREVIOUS_AUTO_DELETE_QUEUES
        Recover earlier auto-delete or exclusive queues that share the same channel as this retry context
      • RETRY_ON_QUEUE_NOT_FOUND_RETRY_HANDLER

        public static final TopologyRecoveryRetryHandlerBuilder RETRY_ON_QUEUE_NOT_FOUND_RETRY_HANDLER
        Pre-configured TopologyRecoveryRetryHandlerBuilder that retries recovery of bindings and consumers when their respective queue is not found. This retry handler can be useful for long recovery processes, whereby auto-delete queues can be deleted between queue recovery and binding/consumer recovery. Also useful to retry channel-closed 404 errors that may arise with auto-delete queues during a cluster cycle.
    • Constructor Detail

      • TopologyRecoveryRetryLogic

        public TopologyRecoveryRetryLogic()