com.rabbitmq.client.impl.recovery

Class TopologyRecoveryRetryLogic

java.lang.Object

com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryLogic

public abstract class TopologyRecoveryRetryLogic
extends Object

Useful ready-to-use conditions and operations for DefaultRetryHandler. They're composed and used with the TopologyRecoveryRetryHandlerBuilder.

Since:

5.4.0

See Also:

DefaultRetryHandler, RetryHandler, TopologyRecoveryRetryHandlerBuilder

Field Summary

Fields

Modifier and Type	Field and Description
static BiPredicate<RecordedEntity,Exception>	CHANNEL_CLOSED_NOT_FOUND Channel has been closed because of a resource that doesn't exist.
static DefaultRetryHandler.RetryOperation<Void>	RECOVER_BINDING Recover a binding.
static DefaultRetryHandler.RetryOperation<Void>	RECOVER_BINDING_QUEUE Recover the destination queue of a binding.
static DefaultRetryHandler.RetryOperation<Void>	RECOVER_CHANNEL Recover a channel.
static DefaultRetryHandler.RetryOperation<String>	RECOVER_CONSUMER Recover a consumer.
static DefaultRetryHandler.RetryOperation<Void>	RECOVER_CONSUMER_QUEUE Recover the queue of a consumer.
static DefaultRetryHandler.RetryOperation<Void>	RECOVER_CONSUMER_QUEUE_BINDINGS Recover all the bindings of the queue of a consumer.
static DefaultRetryHandler.RetryOperation<Void>	RECOVER_PREVIOUS_AUTO_DELETE_QUEUES Recover earlier auto-delete or exclusive queues that share the same channel as this retry context
static DefaultRetryHandler.RetryOperation<String>	RECOVER_PREVIOUS_CONSUMERS Recover earlier consumers that share the same channel as this retry context
static DefaultRetryHandler.RetryOperation<Void>	RECOVER_PREVIOUS_QUEUE_BINDINGS Recover earlier bindings that share the same queue as this retry context
static DefaultRetryHandler.RetryOperation<Void>	RECOVER_QUEUE Recover a queue
static 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.

Constructor Summary

Constructors

Constructor and Description
TopologyRecoveryRetryLogic()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CHANNEL_CLOSED_NOT_FOUND

public static final BiPredicate<RecordedEntity,Exception> CHANNEL_CLOSED_NOT_FOUND

Channel has been closed because of a resource that doesn't exist.

RECOVER_CHANNEL

public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_CHANNEL

Recover a channel.

RECOVER_QUEUE

public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_QUEUE

Recover a queue

RECOVER_BINDING_QUEUE

public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_BINDING_QUEUE

Recover the destination queue of a binding.

RECOVER_BINDING

public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_BINDING

Recover a binding.

RECOVER_PREVIOUS_QUEUE_BINDINGS

public static final DefaultRetryHandler.RetryOperation<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<Void> RECOVER_CONSUMER_QUEUE

Recover the queue of a consumer.

RECOVER_CONSUMER_QUEUE_BINDINGS

public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_CONSUMER_QUEUE_BINDINGS

Recover all the bindings of the queue of a consumer.

RECOVER_CONSUMER

public static final DefaultRetryHandler.RetryOperation<String> RECOVER_CONSUMER

Recover a consumer.

RECOVER_PREVIOUS_CONSUMERS

public static final DefaultRetryHandler.RetryOperation<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<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()