Uses of Class
com.rabbitmq.client.impl.recovery.RecordedEntity
Packages that use RecordedEntity
Package
Description
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
Implementation of connection and topology recovery.
-
Uses of RecordedEntity in com.rabbitmq.client
Fields in com.rabbitmq.client declared as RecordedEntityModifier and TypeFieldDescriptionprivate final RecordedEntity
TopologyRecoveryException.recordedEntity
Methods in com.rabbitmq.client that return RecordedEntityConstructors in com.rabbitmq.client with parameters of type RecordedEntityModifierConstructorDescriptionTopologyRecoveryException
(String message, Throwable cause, RecordedEntity recordedEntity) -
Uses of RecordedEntity in com.rabbitmq.client.impl.recovery
Subclasses of RecordedEntity in com.rabbitmq.client.impl.recoveryModifier and TypeClassDescriptionclass
class
class
class
class
class
class
Fields in com.rabbitmq.client.impl.recovery declared as RecordedEntityModifier and TypeFieldDescriptionprivate final RecordedEntity
RetryContext.entity
private final RecordedEntity
RetryResult.recordedEntity
The entity to recover.Fields in com.rabbitmq.client.impl.recovery with type parameters of type RecordedEntityModifier and TypeFieldDescriptionstatic final BiPredicate
<RecordedEntity, 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 RecordedEntityModifier and TypeMethodDescriptionprivate <E extends RecordedEntity>
List<Callable<Object>> AutorecoveringConnection.groupEntitiesByChannel
(Collection<E> entities) Methods in com.rabbitmq.client.impl.recovery that return RecordedEntityModifier and TypeMethodDescriptionRetryContext.entity()
The to-be-recovered entity.RetryResult.getRecordedEntity()
The entity to recover.Methods in com.rabbitmq.client.impl.recovery with parameters of type RecordedEntityModifier and TypeMethodDescriptionprotected RetryResult
DefaultRetryHandler.doRetry
(BiPredicate<RecordedEntity, Exception> condition, DefaultRetryHandler.RetryOperation<?> operation, RecordedEntity entity, RetryContext context) protected void
DefaultRetryHandler.log
(RecordedEntity entity, Exception exception, int attempts) private <T> RetryResult
AutorecoveringConnection.wrapRetryIfNecessary
(RecordedEntity entity, Callable<T> recoveryAction) Method parameters in com.rabbitmq.client.impl.recovery with type arguments of type RecordedEntityModifier and TypeMethodDescriptionprotected RetryResult
DefaultRetryHandler.doRetry
(BiPredicate<RecordedEntity, Exception> condition, DefaultRetryHandler.RetryOperation<?> operation, RecordedEntity entity, RetryContext context) private void
AutorecoveringConnection.recoverEntitiesAsynchronously
(ExecutorService executor, Collection<? extends RecordedEntity> recordedEntities) Constructors in com.rabbitmq.client.impl.recovery with parameters of type RecordedEntityModifierConstructorDescriptionRetryContext
(RecordedEntity entity, Exception exception, AutorecoveringConnection connection) RetryResult
(RecordedEntity recordedEntity, Object result)