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 final BiPredicate<? super RecordedConsumer,Exception>	DefaultRetryHandler.consumerRecoveryRetryCondition
protected BiPredicate<? super RecordedConsumer,Exception>	TopologyRecoveryRetryHandlerBuilder.consumerRecoveryRetryCondition

Methods in com.rabbitmq.client.impl.recovery that return RecordedConsumer

Modifier and Type	Method	Description
RecordedConsumer	RecordedConsumer.arguments(Map<String,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(String value)
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
Map<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.
void	AutorecoveringConnection.recoverConsumer(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(BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition)