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

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

Modifier and Type	Method and Description
RecordedConsumer	RecordedConsumer.arguments(Map<String,Object> value)
RecordedConsumer	RecordedConsumer.autoAck(boolean value)
RecordedConsumer	RetryContext.consumer() The to-be-recovered entity as a consumer.
RecordedConsumer	RecordedConsumer.consumer(Consumer value)
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 and Description
Map<String,RecordedConsumer>	AutorecoveringConnection.getRecordedConsumers()

Methods in com.rabbitmq.client.impl.recovery with parameters of type RecordedConsumer

Modifier and Type	Method and 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 and Description
TopologyRecoveryRetryHandlerBuilder	TopologyRecoveryRetryHandlerBuilder.consumerRecoveryRetryCondition(BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition)

Constructor parameters in com.rabbitmq.client.impl.recovery with type arguments of type RecordedConsumer

Constructor and Description

DefaultRetryHandler(BiPredicate<? super RecordedQueue,Exception> queueRecoveryRetryCondition, BiPredicate<? super RecordedExchange,Exception> exchangeRecoveryRetryCondition, BiPredicate<? super RecordedBinding,Exception> bindingRecoveryRetryCondition, BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition, DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation, DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation, DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation, DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation, int retryAttempts, BackoffPolicy backoffPolicy)