Package com.rabbitmq.client.impl.recovery

Class TopologyRecoveryRetryHandlerBuilder

java.lang.Object

com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder

public class TopologyRecoveryRetryHandlerBuilder
extends Object

Builder to ease creation of DefaultRetryHandler instances.

Just override what you need. By default, retry conditions don't trigger retry, retry operations are no-op, the number of retry attempts is 2, and the backoff policy doesn't wait at all.

Since:

5.4.0

See Also:

• DefaultRetryHandler
• TopologyRecoveryRetryLogic

Field Summary

Fields

Modifier and Type	Field	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	Description
TopologyRecoveryRetryHandlerBuilder()

Method Summary

Modifier and Type	Method	Description
TopologyRecoveryRetryHandlerBuilder	backoffPolicy(BackoffPolicy backoffPolicy)
TopologyRecoveryRetryHandlerBuilder	bindingRecoveryRetryCondition(BiPredicate<? super RecordedBinding,Exception> bindingRecoveryRetryCondition)
TopologyRecoveryRetryHandlerBuilder	bindingRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation)
RetryHandler	build()
static TopologyRecoveryRetryHandlerBuilder	builder()
TopologyRecoveryRetryHandlerBuilder	consumerRecoveryRetryCondition(BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition)
TopologyRecoveryRetryHandlerBuilder	consumerRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation)
TopologyRecoveryRetryHandlerBuilder	exchangeRecoveryRetryCondition(BiPredicate<? super RecordedExchange,Exception> exchangeRecoveryRetryCondition)
TopologyRecoveryRetryHandlerBuilder	exchangeRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation)
TopologyRecoveryRetryHandlerBuilder	queueRecoveryRetryCondition(BiPredicate<? super RecordedQueue,Exception> queueRecoveryRetryCondition)
TopologyRecoveryRetryHandlerBuilder	queueRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation)
TopologyRecoveryRetryHandlerBuilder	retryAttempts(int retryAttempts)

Methods inherited from class java.lang.Object

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

Field Details

queueRecoveryRetryCondition

protected BiPredicate<? super RecordedQueue,Exception> queueRecoveryRetryCondition

exchangeRecoveryRetryCondition

protected BiPredicate<? super RecordedExchange,Exception> exchangeRecoveryRetryCondition

bindingRecoveryRetryCondition

protected BiPredicate<? super RecordedBinding,Exception> bindingRecoveryRetryCondition

consumerRecoveryRetryCondition

protected BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition

queueRecoveryRetryOperation

protected DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation

exchangeRecoveryRetryOperation

protected DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation

bindingRecoveryRetryOperation

protected DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation

consumerRecoveryRetryOperation

protected DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation

retryAttempts

protected int retryAttempts

backoffPolicy

protected BackoffPolicy backoffPolicy

Constructor Details

TopologyRecoveryRetryHandlerBuilder

public TopologyRecoveryRetryHandlerBuilder()

Method Details

builder

public static TopologyRecoveryRetryHandlerBuilder builder()

queueRecoveryRetryCondition

public TopologyRecoveryRetryHandlerBuilder queueRecoveryRetryCondition(BiPredicate<? super RecordedQueue,Exception> queueRecoveryRetryCondition)

exchangeRecoveryRetryCondition

public TopologyRecoveryRetryHandlerBuilder exchangeRecoveryRetryCondition(BiPredicate<? super RecordedExchange,Exception> exchangeRecoveryRetryCondition)

bindingRecoveryRetryCondition

public TopologyRecoveryRetryHandlerBuilder bindingRecoveryRetryCondition(BiPredicate<? super RecordedBinding,Exception> bindingRecoveryRetryCondition)

consumerRecoveryRetryCondition

public TopologyRecoveryRetryHandlerBuilder consumerRecoveryRetryCondition(BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition)

queueRecoveryRetryOperation

public TopologyRecoveryRetryHandlerBuilder queueRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation)

exchangeRecoveryRetryOperation

public TopologyRecoveryRetryHandlerBuilder exchangeRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation)

bindingRecoveryRetryOperation

public TopologyRecoveryRetryHandlerBuilder bindingRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation)

consumerRecoveryRetryOperation

public TopologyRecoveryRetryHandlerBuilder consumerRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation)

backoffPolicy

public TopologyRecoveryRetryHandlerBuilder backoffPolicy(BackoffPolicy backoffPolicy)

retryAttempts

public TopologyRecoveryRetryHandlerBuilder retryAttempts(int retryAttempts)

build

public RetryHandler build()