Uses of Class
com.rabbitmq.client.impl.recovery.RecordedEntity

Packages that use RecordedEntity

Package	Description
com.rabbitmq.client	The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.
com.rabbitmq.client.impl.recovery	Implementation of connection and topology recovery.

Uses of RecordedEntity in com.rabbitmq.client

Fields in com.rabbitmq.client declared as RecordedEntity

Modifier and Type	Field	Description
private RecordedEntity	TopologyRecoveryException.recordedEntity

Methods in com.rabbitmq.client that return RecordedEntity

Modifier and Type	Method	Description
RecordedEntity	TopologyRecoveryException.getRecordedEntity()

Constructors in com.rabbitmq.client with parameters of type RecordedEntity

Constructor	Description
TopologyRecoveryException(java.lang.String message, java.lang.Throwable cause, RecordedEntity recordedEntity)

Uses of RecordedEntity in com.rabbitmq.client.impl.recovery

Subclasses of RecordedEntity in com.rabbitmq.client.impl.recovery

Modifier and Type	Class	Description
class	RecordedBinding
class	RecordedConsumer
class	RecordedExchange
class	RecordedExchangeBinding
class	RecordedNamedEntity
class	RecordedQueue
class	RecordedQueueBinding

Fields in com.rabbitmq.client.impl.recovery declared as RecordedEntity

Modifier and Type	Field	Description
private RecordedEntity	RetryContext.entity
private RecordedEntity	RetryResult.recordedEntity	The entity to recover.

Fields in com.rabbitmq.client.impl.recovery with type parameters of type RecordedEntity

Modifier and Type	Field	Description
static java.util.function.BiPredicate<RecordedEntity,java.lang.Exception>	TopologyRecoveryRetryLogic.CHANNEL_CLOSED_NOT_FOUND	Channel has been closed because of a resource that doesn't exist.

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

Modifier and Type	Method	Description
private <E extends RecordedEntity> java.util.List<java.util.concurrent.Callable<java.lang.Object>>	AutorecoveringConnection.groupEntitiesByChannel(java.util.Collection<E> entities)

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

Modifier and Type	Method	Description
RecordedEntity	RetryContext.entity()	The to-be-recovered entity.
RecordedEntity	RetryResult.getRecordedEntity()	The entity to recover.

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

Modifier and Type	Method	Description
protected RetryResult	DefaultRetryHandler.doRetry(java.util.function.BiPredicate<RecordedEntity,java.lang.Exception> condition, DefaultRetryHandler.RetryOperation<?> operation, RecordedEntity entity, RetryContext context)
protected void	DefaultRetryHandler.log(RecordedEntity entity, java.lang.Exception exception, int attempts)
private <T> RetryResult	AutorecoveringConnection.wrapRetryIfNecessary(RecordedEntity entity, java.util.concurrent.Callable<T> recoveryAction)

Method parameters in com.rabbitmq.client.impl.recovery with type arguments of type RecordedEntity

Modifier and Type	Method	Description
protected RetryResult	DefaultRetryHandler.doRetry(java.util.function.BiPredicate<RecordedEntity,java.lang.Exception> condition, DefaultRetryHandler.RetryOperation<?> operation, RecordedEntity entity, RetryContext context)
private void	AutorecoveringConnection.recoverEntitiesAsynchronously(java.util.concurrent.ExecutorService executor, java.util.Collection<? extends RecordedEntity> recordedEntities)

Constructors in com.rabbitmq.client.impl.recovery with parameters of type RecordedEntity

Constructor	Description
RetryContext(RecordedEntity entity, java.lang.Exception exception, AutorecoveringConnection connection)
RetryResult(RecordedEntity recordedEntity, java.lang.Object result)