Uses of Class
com.rabbitmq.client.impl.recovery.RecordedQueue
-
Packages that use RecordedQueue Package Description com.rabbitmq.client.impl.recovery 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 RecordedQueue Modifier and Type Field Description protected java.util.function.BiPredicate<? super RecordedQueue,java.lang.Exception>
DefaultRetryHandler. queueRecoveryRetryCondition
protected java.util.function.BiPredicate<? super RecordedQueue,java.lang.Exception>
TopologyRecoveryRetryHandlerBuilder. queueRecoveryRetryCondition
private java.util.Map<java.lang.String,RecordedQueue>
AutorecoveringConnection. recordedQueues
Methods in com.rabbitmq.client.impl.recovery that return RecordedQueue Modifier and Type Method Description RecordedQueue
RecordedQueue. arguments(java.util.Map<java.lang.String,java.lang.Object> value)
RecordedQueue
RecordedQueue. autoDelete(boolean value)
RecordedQueue
RecordedQueue. durable(boolean value)
RecordedQueue
RecordedQueue. exclusive(boolean value)
RecordedQueue
RetryContext. queue()
The to-be-recovered entity as a queue.RecordedQueue
RecordedQueue. recoveredQueueNameSupplier(RecoveredQueueNameSupplier recoveredQueueNameSupplier)
RecordedQueue
RecordedQueue. serverNamed(boolean value)
Methods in com.rabbitmq.client.impl.recovery that return types with arguments of type RecordedQueue Modifier and Type Method Description java.util.Map<java.lang.String,RecordedQueue>
AutorecoveringConnection. getRecordedQueues()
Methods in com.rabbitmq.client.impl.recovery with parameters of type RecordedQueue Modifier and Type Method Description default boolean
TopologyRecoveryFilter. filterQueue(RecordedQueue recordedQueue)
Decides whether a queue is recovered or not.java.lang.String
RecoveredQueueNameSupplier. getNameToUseForRecovery(RecordedQueue recordedQueue)
Get the queue name to use when recovering this RecordedQueue entityprivate void
AutorecoveringConnection. internalRecoverQueue(java.lang.String oldName, RecordedQueue q, boolean retry)
private void
AutorecoveringChannel. recordQueue(AMQP.Queue.DeclareOk ok, RecordedQueue q)
private void
AutorecoveringChannel. recordQueue(java.lang.String queue, RecordedQueue meta)
(package private) void
AutorecoveringConnection. recordQueue(AMQP.Queue.DeclareOk ok, RecordedQueue q)
(package private) void
AutorecoveringConnection. recordQueue(java.lang.String queue, RecordedQueue meta)
(package private) void
AutorecoveringConnection. recoverQueue(java.lang.String oldName, RecordedQueue q)
Recover the queue.void
AutorecoveringConnection. recoverQueue(java.lang.String oldName, RecordedQueue q, boolean retry)
Recover the queue.Method parameters in com.rabbitmq.client.impl.recovery with type arguments of type RecordedQueue Modifier and Type Method Description TopologyRecoveryRetryHandlerBuilder
TopologyRecoveryRetryHandlerBuilder. queueRecoveryRetryCondition(java.util.function.BiPredicate<? super RecordedQueue,java.lang.Exception> queueRecoveryRetryCondition)
Constructor parameters in com.rabbitmq.client.impl.recovery with type arguments of type RecordedQueue Constructor Description DefaultRetryHandler(java.util.function.BiPredicate<? super RecordedQueue,java.lang.Exception> queueRecoveryRetryCondition, java.util.function.BiPredicate<? super RecordedExchange,java.lang.Exception> exchangeRecoveryRetryCondition, java.util.function.BiPredicate<? super RecordedBinding,java.lang.Exception> bindingRecoveryRetryCondition, java.util.function.BiPredicate<? super RecordedConsumer,java.lang.Exception> consumerRecoveryRetryCondition, DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation, DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation, DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation, DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation, int retryAttempts, BackoffPolicy backoffPolicy)
-