Uses of Interface
com.rabbitmq.client.impl.recovery.DefaultRetryHandler.RetryOperation
Packages that use DefaultRetryHandler.RetryOperation
Package
Description
Implementation of connection and topology recovery.
-
Uses of DefaultRetryHandler.RetryOperation in com.rabbitmq.client.impl.recovery
Fields in com.rabbitmq.client.impl.recovery declared as DefaultRetryHandler.RetryOperationModifier and TypeFieldDescriptionprotected final DefaultRetryHandler.RetryOperation<?> DefaultRetryHandler.bindingRecoveryRetryOperationprotected DefaultRetryHandler.RetryOperation<?> TopologyRecoveryRetryHandlerBuilder.bindingRecoveryRetryOperationprotected final DefaultRetryHandler.RetryOperation<?> DefaultRetryHandler.consumerRecoveryRetryOperationprotected DefaultRetryHandler.RetryOperation<?> TopologyRecoveryRetryHandlerBuilder.consumerRecoveryRetryOperationprotected final DefaultRetryHandler.RetryOperation<?> DefaultRetryHandler.exchangeRecoveryRetryOperationprotected DefaultRetryHandler.RetryOperation<?> TopologyRecoveryRetryHandlerBuilder.exchangeRecoveryRetryOperationprotected final DefaultRetryHandler.RetryOperation<?> DefaultRetryHandler.queueRecoveryRetryOperationprotected DefaultRetryHandler.RetryOperation<?> TopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryOperationstatic final DefaultRetryHandler.RetryOperation<Void> TopologyRecoveryRetryLogic.RECOVER_BINDINGRecover a binding.static final DefaultRetryHandler.RetryOperation<Void> TopologyRecoveryRetryLogic.RECOVER_BINDING_QUEUERecover the destination queue of a binding.static final DefaultRetryHandler.RetryOperation<Void> TopologyRecoveryRetryLogic.RECOVER_CHANNELRecover a channel.static final DefaultRetryHandler.RetryOperation<String> TopologyRecoveryRetryLogic.RECOVER_CONSUMERRecover a consumer.static final DefaultRetryHandler.RetryOperation<Void> TopologyRecoveryRetryLogic.RECOVER_CONSUMER_QUEUERecover the queue of a consumer.static final DefaultRetryHandler.RetryOperation<Void> TopologyRecoveryRetryLogic.RECOVER_CONSUMER_QUEUE_BINDINGSRecover all the bindings of the queue of a consumer.static final DefaultRetryHandler.RetryOperation<Void> TopologyRecoveryRetryLogic.RECOVER_PREVIOUS_AUTO_DELETE_QUEUESRecover earlier auto-delete or exclusive queues that share the same channel as this retry contextstatic final DefaultRetryHandler.RetryOperation<String> TopologyRecoveryRetryLogic.RECOVER_PREVIOUS_CONSUMERSRecover earlier consumers that share the same channel as this retry contextstatic final DefaultRetryHandler.RetryOperation<Void> TopologyRecoveryRetryLogic.RECOVER_PREVIOUS_QUEUE_BINDINGSRecover earlier bindings that share the same queue as this retry contextstatic final DefaultRetryHandler.RetryOperation<Void> TopologyRecoveryRetryLogic.RECOVER_QUEUERecover a queueMethods in com.rabbitmq.client.impl.recovery that return DefaultRetryHandler.RetryOperationModifier and TypeMethodDescriptiondefault <V> DefaultRetryHandler.RetryOperation<V> DefaultRetryHandler.RetryOperation.andThen(DefaultRetryHandler.RetryOperation<V> after) Methods in com.rabbitmq.client.impl.recovery with parameters of type DefaultRetryHandler.RetryOperationModifier and TypeMethodDescriptiondefault <V> DefaultRetryHandler.RetryOperation<V> DefaultRetryHandler.RetryOperation.andThen(DefaultRetryHandler.RetryOperation<V> after) TopologyRecoveryRetryHandlerBuilder.bindingRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation) TopologyRecoveryRetryHandlerBuilder.consumerRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation) protected RetryResultDefaultRetryHandler.doRetry(BiPredicate<RecordedEntity, Exception> condition, DefaultRetryHandler.RetryOperation<?> operation, RecordedEntity entity, RetryContext context) TopologyRecoveryRetryHandlerBuilder.exchangeRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation) TopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation) Constructors in com.rabbitmq.client.impl.recovery with parameters of type DefaultRetryHandler.RetryOperationModifierConstructorDescriptionDefaultRetryHandler(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)