Class TopologyRecoveryRetryHandlerBuilder
- java.lang.Object
-
- com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
-
public class TopologyRecoveryRetryHandlerBuilder extends java.lang.Object
Builder to ease creation ofDefaultRetryHandler
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 java.util.function.BiPredicate<? super RecordedBinding,java.lang.Exception>
bindingRecoveryRetryCondition
protected DefaultRetryHandler.RetryOperation<?>
bindingRecoveryRetryOperation
protected java.util.function.BiPredicate<? super RecordedConsumer,java.lang.Exception>
consumerRecoveryRetryCondition
protected DefaultRetryHandler.RetryOperation<?>
consumerRecoveryRetryOperation
protected java.util.function.BiPredicate<? super RecordedExchange,java.lang.Exception>
exchangeRecoveryRetryCondition
protected DefaultRetryHandler.RetryOperation<?>
exchangeRecoveryRetryOperation
protected java.util.function.BiPredicate<? super RecordedQueue,java.lang.Exception>
queueRecoveryRetryCondition
protected DefaultRetryHandler.RetryOperation<?>
queueRecoveryRetryOperation
protected int
retryAttempts
-
Constructor Summary
Constructors Constructor Description TopologyRecoveryRetryHandlerBuilder()
-
Method Summary
-
-
-
Field Detail
-
queueRecoveryRetryCondition
protected java.util.function.BiPredicate<? super RecordedQueue,java.lang.Exception> queueRecoveryRetryCondition
-
exchangeRecoveryRetryCondition
protected java.util.function.BiPredicate<? super RecordedExchange,java.lang.Exception> exchangeRecoveryRetryCondition
-
bindingRecoveryRetryCondition
protected java.util.function.BiPredicate<? super RecordedBinding,java.lang.Exception> bindingRecoveryRetryCondition
-
consumerRecoveryRetryCondition
protected java.util.function.BiPredicate<? super RecordedConsumer,java.lang.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
-
-
Method Detail
-
builder
public static TopologyRecoveryRetryHandlerBuilder builder()
-
queueRecoveryRetryCondition
public TopologyRecoveryRetryHandlerBuilder queueRecoveryRetryCondition(java.util.function.BiPredicate<? super RecordedQueue,java.lang.Exception> queueRecoveryRetryCondition)
-
exchangeRecoveryRetryCondition
public TopologyRecoveryRetryHandlerBuilder exchangeRecoveryRetryCondition(java.util.function.BiPredicate<? super RecordedExchange,java.lang.Exception> exchangeRecoveryRetryCondition)
-
bindingRecoveryRetryCondition
public TopologyRecoveryRetryHandlerBuilder bindingRecoveryRetryCondition(java.util.function.BiPredicate<? super RecordedBinding,java.lang.Exception> bindingRecoveryRetryCondition)
-
consumerRecoveryRetryCondition
public TopologyRecoveryRetryHandlerBuilder consumerRecoveryRetryCondition(java.util.function.BiPredicate<? super RecordedConsumer,java.lang.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()
-
-