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:

4.8.0

See Also:

DefaultRetryHandler, RetryHandler, TopologyRecoveryRetryHandlerBuilder

Field Summary

Fields

Modifier and Type	Field	Description
static DefaultRetryHandler.RetryCondition<RecordedEntity>	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 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 Detail

CHANNEL_CLOSED_NOT_FOUND

public static final DefaultRetryHandler.RetryCondition<RecordedEntity> 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_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_CONSUMER_QUEUE

public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_CONSUMER_QUEUE

Recover the queue of a consumer.

RECOVER_CONSUMER

public static final DefaultRetryHandler.RetryOperation<String> RECOVER_CONSUMER

Recover 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.

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.

Constructor Detail

TopologyRecoveryRetryLogic

public TopologyRecoveryRetryLogic()