Class TopologyRecoveryRetryLogic
- java.lang.Object
-
- com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryLogic
-
public abstract class TopologyRecoveryRetryLogic extends java.lang.Object
Useful ready-to-use conditions and operations forDefaultRetryHandler
. They're composed and used with theTopologyRecoveryRetryHandlerBuilder
.- Since:
- 5.4.0
- See Also:
DefaultRetryHandler
,RetryHandler
,TopologyRecoveryRetryHandlerBuilder
-
-
Field Summary
Fields Modifier and Type Field Description static java.util.function.BiPredicate<RecordedEntity,java.lang.Exception>
CHANNEL_CLOSED_NOT_FOUND
Channel has been closed because of a resource that doesn't exist.static DefaultRetryHandler.RetryOperation<java.lang.Void>
RECOVER_BINDING
Recover a binding.static DefaultRetryHandler.RetryOperation<java.lang.Void>
RECOVER_BINDING_QUEUE
Recover the destination queue of a binding.static DefaultRetryHandler.RetryOperation<java.lang.Void>
RECOVER_CHANNEL
Recover a channel.static DefaultRetryHandler.RetryOperation<java.lang.String>
RECOVER_CONSUMER
Recover a consumer.static DefaultRetryHandler.RetryOperation<java.lang.Void>
RECOVER_CONSUMER_QUEUE
Recover the queue of a consumer.static DefaultRetryHandler.RetryOperation<java.lang.Void>
RECOVER_CONSUMER_QUEUE_BINDINGS
Recover all the bindings of the queue of a consumer.static 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 contextstatic DefaultRetryHandler.RetryOperation<java.lang.String>
RECOVER_PREVIOUS_CONSUMERS
Recover earlier consumers that share the same channel as this retry contextstatic DefaultRetryHandler.RetryOperation<java.lang.Void>
RECOVER_PREVIOUS_QUEUE_BINDINGS
Recover earlier bindings that share the same queue as this retry contextstatic DefaultRetryHandler.RetryOperation<java.lang.Void>
RECOVER_QUEUE
Recover a queuestatic TopologyRecoveryRetryHandlerBuilder
RETRY_ON_QUEUE_NOT_FOUND_RETRY_HANDLER
Pre-configuredTopologyRecoveryRetryHandlerBuilder
that retries recovery of bindings and consumers when their respective queue is not found.
-
Constructor Summary
Constructors Constructor Description 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_CHANNEL
public static final DefaultRetryHandler.RetryOperation<java.lang.Void> RECOVER_CHANNEL
Recover a channel.
-
RECOVER_QUEUE
public static final DefaultRetryHandler.RetryOperation<java.lang.Void> RECOVER_QUEUE
Recover a queue
-
RECOVER_BINDING_QUEUE
public static final DefaultRetryHandler.RetryOperation<java.lang.Void> RECOVER_BINDING_QUEUE
Recover the destination queue of a binding.
-
RECOVER_BINDING
public static final DefaultRetryHandler.RetryOperation<java.lang.Void> RECOVER_BINDING
Recover a binding.
-
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
public static final DefaultRetryHandler.RetryOperation<java.lang.Void> RECOVER_CONSUMER_QUEUE
Recover the queue of a consumer.
-
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_CONSUMER
public static final DefaultRetryHandler.RetryOperation<java.lang.String> RECOVER_CONSUMER
Recover 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-configuredTopologyRecoveryRetryHandlerBuilder
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.
-
-