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. queueRecoveryRetryConditionprotected java.util.function.BiPredicate<? super RecordedQueue,java.lang.Exception>TopologyRecoveryRetryHandlerBuilder. queueRecoveryRetryConditionprivate java.util.Map<java.lang.String,RecordedQueue>AutorecoveringConnection. recordedQueuesMethods in com.rabbitmq.client.impl.recovery that return RecordedQueue Modifier and Type Method Description RecordedQueueRecordedQueue. arguments(java.util.Map<java.lang.String,java.lang.Object> value)RecordedQueueRecordedQueue. autoDelete(boolean value)RecordedQueueRecordedQueue. durable(boolean value)RecordedQueueRecordedQueue. exclusive(boolean value)RecordedQueueRetryContext. queue()The to-be-recovered entity as a queue.RecordedQueueRecordedQueue. recoveredQueueNameSupplier(RecoveredQueueNameSupplier recoveredQueueNameSupplier)RecordedQueueRecordedQueue. 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 booleanTopologyRecoveryFilter. filterQueue(RecordedQueue recordedQueue)Decides whether a queue is recovered or not.java.lang.StringRecoveredQueueNameSupplier. getNameToUseForRecovery(RecordedQueue recordedQueue)Get the queue name to use when recovering this RecordedQueue entityprivate voidAutorecoveringConnection. internalRecoverQueue(java.lang.String oldName, RecordedQueue q, boolean retry)private voidAutorecoveringChannel. recordQueue(AMQP.Queue.DeclareOk ok, RecordedQueue q)private voidAutorecoveringChannel. recordQueue(java.lang.String queue, RecordedQueue meta)(package private) voidAutorecoveringConnection. recordQueue(AMQP.Queue.DeclareOk ok, RecordedQueue q)(package private) voidAutorecoveringConnection. recordQueue(java.lang.String queue, RecordedQueue meta)(package private) voidAutorecoveringConnection. recoverQueue(java.lang.String oldName, RecordedQueue q)Recover the queue.voidAutorecoveringConnection. 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 TopologyRecoveryRetryHandlerBuilderTopologyRecoveryRetryHandlerBuilder. 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)
-