Uses of Interface
com.rabbitmq.client.impl.recovery.DefaultRetryHandler.RetryOperation
Package
Description
Implementation of connection and topology recovery.
-
Uses of DefaultRetryHandler.RetryOperation in com.rabbitmq.client.impl.recovery
Modifier and TypeFieldDescriptionprotected final DefaultRetryHandler.RetryOperation
<?> DefaultRetryHandler.bindingRecoveryRetryOperation
protected DefaultRetryHandler.RetryOperation
<?> TopologyRecoveryRetryHandlerBuilder.bindingRecoveryRetryOperation
protected final DefaultRetryHandler.RetryOperation
<?> DefaultRetryHandler.consumerRecoveryRetryOperation
protected DefaultRetryHandler.RetryOperation
<?> TopologyRecoveryRetryHandlerBuilder.consumerRecoveryRetryOperation
protected final DefaultRetryHandler.RetryOperation
<?> DefaultRetryHandler.exchangeRecoveryRetryOperation
protected DefaultRetryHandler.RetryOperation
<?> TopologyRecoveryRetryHandlerBuilder.exchangeRecoveryRetryOperation
protected final DefaultRetryHandler.RetryOperation
<?> DefaultRetryHandler.queueRecoveryRetryOperation
protected DefaultRetryHandler.RetryOperation
<?> TopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryOperation
static final DefaultRetryHandler.RetryOperation
<Void> TopologyRecoveryRetryLogic.RECOVER_BINDING
Recover a binding.static final DefaultRetryHandler.RetryOperation
<Void> TopologyRecoveryRetryLogic.RECOVER_BINDING_QUEUE
Recover the destination queue of a binding.static final DefaultRetryHandler.RetryOperation
<Void> TopologyRecoveryRetryLogic.RECOVER_CHANNEL
Recover a channel.static final DefaultRetryHandler.RetryOperation
<String> TopologyRecoveryRetryLogic.RECOVER_CONSUMER
Recover a consumer.static final DefaultRetryHandler.RetryOperation
<Void> TopologyRecoveryRetryLogic.RECOVER_CONSUMER_QUEUE
Recover the queue of a consumer.static final DefaultRetryHandler.RetryOperation
<Void> TopologyRecoveryRetryLogic.RECOVER_CONSUMER_QUEUE_BINDINGS
Recover all the bindings of the queue of a consumer.static final DefaultRetryHandler.RetryOperation
<Void> TopologyRecoveryRetryLogic.RECOVER_PREVIOUS_AUTO_DELETE_QUEUES
Recover earlier auto-delete or exclusive queues that share the same channel as this retry contextstatic final DefaultRetryHandler.RetryOperation
<String> TopologyRecoveryRetryLogic.RECOVER_PREVIOUS_CONSUMERS
Recover earlier consumers that share the same channel as this retry contextstatic final DefaultRetryHandler.RetryOperation
<Void> TopologyRecoveryRetryLogic.RECOVER_PREVIOUS_QUEUE_BINDINGS
Recover earlier bindings that share the same queue as this retry contextstatic final DefaultRetryHandler.RetryOperation
<Void> TopologyRecoveryRetryLogic.RECOVER_QUEUE
Recover a queueModifier and TypeMethodDescriptiondefault <V> DefaultRetryHandler.RetryOperation
<V> DefaultRetryHandler.RetryOperation.andThen
(DefaultRetryHandler.RetryOperation<V> after) Modifier and TypeMethodDescriptiondefault <V> DefaultRetryHandler.RetryOperation
<V> DefaultRetryHandler.RetryOperation.andThen
(DefaultRetryHandler.RetryOperation<V> after) TopologyRecoveryRetryHandlerBuilder.bindingRecoveryRetryOperation
(DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation) TopologyRecoveryRetryHandlerBuilder.consumerRecoveryRetryOperation
(DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation) protected RetryResult
DefaultRetryHandler.doRetry
(BiPredicate<RecordedEntity, Exception> condition, DefaultRetryHandler.RetryOperation<?> operation, RecordedEntity entity, RetryContext context) TopologyRecoveryRetryHandlerBuilder.exchangeRecoveryRetryOperation
(DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation) TopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryOperation
(DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation) ModifierConstructorDescriptionDefaultRetryHandler
(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)