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

Constructor Summary

Constructors

Constructor	Description
TopologyRecoveryRetryLogic()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

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 Details

TopologyRecoveryRetryLogic

public TopologyRecoveryRetryLogic()