Uses of Class
com.rabbitmq.client.impl.recovery.RecordedQueue
Packages that use RecordedQueue
Package
Description
Implementation of connection and topology recovery.
-
Uses of RecordedQueue in com.rabbitmq.client.impl.recovery
Fields in com.rabbitmq.client.impl.recovery with type parameters of type RecordedQueueModifier and TypeFieldDescriptionprotected final BiPredicate
<? super RecordedQueue, Exception> DefaultRetryHandler.queueRecoveryRetryCondition
protected BiPredicate
<? super RecordedQueue, Exception> TopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryCondition
Methods in com.rabbitmq.client.impl.recovery that return RecordedQueueModifier and TypeMethodDescriptionRecordedQueue.autoDelete
(boolean value) RecordedQueue.durable
(boolean value) RecordedQueue.exclusive
(boolean value) RetryContext.queue()
The to-be-recovered entity as a queue.RecordedQueue.recoveredQueueNameSupplier
(RecoveredQueueNameSupplier recoveredQueueNameSupplier) RecordedQueue.serverNamed
(boolean value) Methods in com.rabbitmq.client.impl.recovery that return types with arguments of type RecordedQueueMethods in com.rabbitmq.client.impl.recovery with parameters of type RecordedQueueModifier and TypeMethodDescriptiondefault boolean
TopologyRecoveryFilter.filterQueue
(RecordedQueue recordedQueue) Decides whether a queue is recovered or not.RecoveredQueueNameSupplier.getNameToUseForRecovery
(RecordedQueue recordedQueue) Get the queue name to use when recovering this RecordedQueue entityvoid
AutorecoveringConnection.recoverQueue
(String oldName, RecordedQueue q, boolean retry) Recover the queue.Method parameters in com.rabbitmq.client.impl.recovery with type arguments of type RecordedQueueModifier and TypeMethodDescriptionTopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryCondition
(BiPredicate<? super RecordedQueue, Exception> queueRecoveryRetryCondition) Constructor parameters in com.rabbitmq.client.impl.recovery with type arguments of type RecordedQueueModifierConstructorDescriptionDefaultRetryHandler
(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)