Uses of Class
com.rabbitmq.client.impl.recovery.RecordedQueue
Package
Description
Implementation of connection and topology recovery.
-
Uses of RecordedQueue in com.rabbitmq.client.impl.recovery
Modifier and TypeFieldDescriptionprotected final BiPredicate
<? super RecordedQueue, Exception> DefaultRetryHandler.queueRecoveryRetryCondition
protected BiPredicate
<? super RecordedQueue, Exception> TopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryCondition
Modifier 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) Modifier 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.Modifier and TypeMethodDescriptionTopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryCondition
(BiPredicate<? super RecordedQueue, Exception> queueRecoveryRetryCondition) 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)