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 RecordedEntityTopologyRecoveryException.recordedEntityMethods 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 TypeClassDescriptionclassclassclassclassclassclassclassFields in com.rabbitmq.client.impl.recovery declared as RecordedEntityModifier and TypeFieldDescriptionprivate final RecordedEntityRetryContext.entityprivate final RecordedEntityRetryResult.recordedEntityThe 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_FOUNDChannel 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 RetryResultDefaultRetryHandler.doRetry(BiPredicate<RecordedEntity, Exception> condition, DefaultRetryHandler.RetryOperation<?> operation, RecordedEntity entity, RetryContext context) protected voidDefaultRetryHandler.log(RecordedEntity entity, Exception exception, int attempts) private <T> RetryResultAutorecoveringConnection.wrapRetryIfNecessary(RecordedEntity entity, Callable<T> recoveryAction) Method parameters in com.rabbitmq.client.impl.recovery with type arguments of type RecordedEntityModifier and TypeMethodDescriptionprotected RetryResultDefaultRetryHandler.doRetry(BiPredicate<RecordedEntity, Exception> condition, DefaultRetryHandler.RetryOperation<?> operation, RecordedEntity entity, RetryContext context) private voidAutorecoveringConnection.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)