Uses of Class
com.rabbitmq.client.impl.recovery.RecordedConsumer
-
Packages that use RecordedConsumer Package Description com.rabbitmq.client.impl.recovery Implementation of connection and topology recovery. -
-
Uses of RecordedConsumer in com.rabbitmq.client.impl.recovery
Fields in com.rabbitmq.client.impl.recovery with type parameters of type RecordedConsumer Modifier and Type Field Description protected java.util.function.BiPredicate<? super RecordedConsumer,java.lang.Exception>
DefaultRetryHandler. consumerRecoveryRetryCondition
protected java.util.function.BiPredicate<? super RecordedConsumer,java.lang.Exception>
TopologyRecoveryRetryHandlerBuilder. consumerRecoveryRetryCondition
private java.util.Map<java.lang.String,RecordedConsumer>
AutorecoveringConnection. consumers
Methods in com.rabbitmq.client.impl.recovery that return RecordedConsumer Modifier and Type Method Description RecordedConsumer
RecordedConsumer. arguments(java.util.Map<java.lang.String,java.lang.Object> value)
RecordedConsumer
RecordedConsumer. autoAck(boolean value)
RecordedConsumer
RecordedConsumer. consumer(Consumer value)
RecordedConsumer
RetryContext. consumer()
The to-be-recovered entity as a consumer.RecordedConsumer
RecordedConsumer. consumerTag(java.lang.String value)
(package private) RecordedConsumer
AutorecoveringConnection. deleteRecordedConsumer(java.lang.String consumerTag)
RecordedConsumer
RecordedConsumer. exclusive(boolean value)
Methods in com.rabbitmq.client.impl.recovery that return types with arguments of type RecordedConsumer Modifier and Type Method Description java.util.Map<java.lang.String,RecordedConsumer>
AutorecoveringConnection. getRecordedConsumers()
Methods in com.rabbitmq.client.impl.recovery with parameters of type RecordedConsumer Modifier and Type Method Description default boolean
TopologyRecoveryFilter. filterConsumer(RecordedConsumer recordedConsumer)
Decides whether a consumer is recovered or not.private void
AutorecoveringConnection. internalRecoverConsumer(java.lang.String tag, RecordedConsumer consumer, boolean retry)
(package private) void
AutorecoveringConnection. recordConsumer(java.lang.String result, RecordedConsumer consumer)
(package private) void
AutorecoveringConnection. recoverConsumer(java.lang.String tag, RecordedConsumer consumer)
Recover the consumer.void
AutorecoveringConnection. recoverConsumer(java.lang.String tag, RecordedConsumer consumer, boolean retry)
Recover the consumer.Method parameters in com.rabbitmq.client.impl.recovery with type arguments of type RecordedConsumer Modifier and Type Method Description TopologyRecoveryRetryHandlerBuilder
TopologyRecoveryRetryHandlerBuilder. consumerRecoveryRetryCondition(java.util.function.BiPredicate<? super RecordedConsumer,java.lang.Exception> consumerRecoveryRetryCondition)
(package private) boolean
AutorecoveringConnection. hasMoreConsumersOnQueue(java.util.Collection<RecordedConsumer> consumers, java.lang.String queue)
-