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)
-