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)