com.rabbitmq.client.impl.recovery

Class DefaultRetryHandler

java.lang.Object

com.rabbitmq.client.impl.recovery.DefaultRetryHandler

All Implemented Interfaces:

RetryHandler

public class DefaultRetryHandler
extends Object
implements RetryHandler

Composable topology recovery retry handler. This retry handler implementations let the user choose the condition to trigger retry and the retry operation for each type of recoverable entities. The number of attempts and the backoff policy (time to wait between retries) are also configurable.

See also TopologyRecoveryRetryHandlerBuilder to easily create instances and TopologyRecoveryRetryLogic for ready-to-use conditions and operations.

Since:

5.4.0

See Also:

TopologyRecoveryRetryHandlerBuilder, TopologyRecoveryRetryLogic

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DefaultRetryHandler.RetryOperation<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected BackoffPolicy	backoffPolicy
protected BiPredicate<? super RecordedBinding,Exception>	bindingRecoveryRetryCondition
protected DefaultRetryHandler.RetryOperation<?>	bindingRecoveryRetryOperation
protected BiPredicate<? super RecordedConsumer,Exception>	consumerRecoveryRetryCondition
protected DefaultRetryHandler.RetryOperation<?>	consumerRecoveryRetryOperation
protected BiPredicate<? super RecordedExchange,Exception>	exchangeRecoveryRetryCondition
protected DefaultRetryHandler.RetryOperation<?>	exchangeRecoveryRetryOperation
protected BiPredicate<? super RecordedQueue,Exception>	queueRecoveryRetryCondition
protected DefaultRetryHandler.RetryOperation<?>	queueRecoveryRetryOperation
protected int	retryAttempts

Constructor Summary

Constructors

Constructor and Description

DefaultRetryHandler(BiPredicate<? super RecordedQueue,Exception> queueRecoveryRetryCondition, BiPredicate<? super RecordedExchange,Exception> exchangeRecoveryRetryCondition, BiPredicate<? super RecordedBinding,Exception> bindingRecoveryRetryCondition, BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition, DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation, DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation, DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation, DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation, int retryAttempts, BackoffPolicy backoffPolicy)

Method Summary

Modifier and Type	Method and Description
protected RetryResult	doRetry(BiPredicate<RecordedEntity,Exception> condition, DefaultRetryHandler.RetryOperation<?> operation, RecordedEntity entity, RetryContext context)
protected void	log(RecordedEntity entity, Exception exception, int attempts)
RetryResult	retryBindingRecovery(RetryContext context) Retry a failed binding recovery operation.
RetryResult	retryConsumerRecovery(RetryContext context) Retry a failed consumer recovery operation.
RetryResult	retryExchangeRecovery(RetryContext context) Retry a failed exchange recovery operation.
RetryResult	retryQueueRecovery(RetryContext context) Retry a failed queue recovery operation.

Methods inherited from class java.lang.Object

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

Field Detail

queueRecoveryRetryCondition

protected final BiPredicate<? super RecordedQueue,Exception> queueRecoveryRetryCondition

exchangeRecoveryRetryCondition

protected final BiPredicate<? super RecordedExchange,Exception> exchangeRecoveryRetryCondition

bindingRecoveryRetryCondition

protected final BiPredicate<? super RecordedBinding,Exception> bindingRecoveryRetryCondition

consumerRecoveryRetryCondition

protected final BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition

queueRecoveryRetryOperation

protected final DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation

exchangeRecoveryRetryOperation

protected final DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation

bindingRecoveryRetryOperation

protected final DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation

consumerRecoveryRetryOperation

protected final DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation

retryAttempts

protected final int retryAttempts

backoffPolicy

protected final BackoffPolicy backoffPolicy

Constructor Detail

DefaultRetryHandler

public DefaultRetryHandler(BiPredicate<? super RecordedQueue,Exception> queueRecoveryRetryCondition,
                           BiPredicate<? super RecordedExchange,Exception> exchangeRecoveryRetryCondition,
                           BiPredicate<? super RecordedBinding,Exception> bindingRecoveryRetryCondition,
                           BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition,
                           DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation,
                           DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation,
                           DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation,
                           DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation,
                           int retryAttempts,
                           BackoffPolicy backoffPolicy)

Method Detail

retryQueueRecovery

public RetryResult retryQueueRecovery(RetryContext context)
                               throws Exception

Description copied from interface: RetryHandler

Retry a failed queue recovery operation.

Specified by:

retryQueueRecovery in interface RetryHandler

Parameters:

context - the context of the retry

Returns:

the result of the retry attempt

Throws:

Exception - if the retry fails

retryExchangeRecovery

public RetryResult retryExchangeRecovery(RetryContext context)
                                  throws Exception

Description copied from interface: RetryHandler

Retry a failed exchange recovery operation.

Specified by:

retryExchangeRecovery in interface RetryHandler

Parameters:

context - the context of the retry

Returns:

the result of the retry attempt

Throws:

Exception - if the retry fails

retryBindingRecovery

public RetryResult retryBindingRecovery(RetryContext context)
                                 throws Exception

Description copied from interface: RetryHandler

Retry a failed binding recovery operation.

Specified by:

retryBindingRecovery in interface RetryHandler

Parameters:

context - the context of the retry

Returns:

the result of the retry attempt

Throws:

Exception - if the retry fails

retryConsumerRecovery

public RetryResult retryConsumerRecovery(RetryContext context)
                                  throws Exception

Description copied from interface: RetryHandler

Retry a failed consumer recovery operation.

Specified by:

retryConsumerRecovery in interface RetryHandler

Parameters:

context - the context of the retry

Returns:

the result of the retry attempt

Throws:

Exception - if the retry fails

doRetry

protected RetryResult doRetry(BiPredicate<RecordedEntity,Exception> condition,
                              DefaultRetryHandler.RetryOperation<?> operation,
                              RecordedEntity entity,
                              RetryContext context)
                       throws Exception

Throws:

Exception

log

protected void log(RecordedEntity entity,
                   Exception exception,
                   int attempts)