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.queueRecoveryRetryConditionprotected BiPredicate<? super RecordedQueue, Exception> TopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryConditionMethods 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 booleanTopologyRecoveryFilter.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 entityvoidAutorecoveringConnection.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)