Package com.rabbitmq.client.impl.recovery
Implementation of connection and topology recovery.
-
Interface Summary Interface Description BackoffPolicy Backoff policy for topology recovery retry attempts.ConsumerRecoveryListener Not part of the public API.QueueRecoveryListener Not part of the public API.RecoveryCanBeginListener Used internally to indicate when connection recovery can begin.RetryHandler Contract to retry failed operations during topology recovery.TopologyRecoveryFilter Filter to know whether entities should be recovered or not. -
Class Summary Class Description AutorecoveringChannel Channelimplementation that is automatically recovered during connection recovery.AutorecoveringConnection Connection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e.g.DefaultRetryHandler Composable topology recovery retry handler.DefaultRetryHandler.RetryCondition<E extends RecordedEntity> DefaultRetryHandler.RetryOperation<T> RecordedBinding RecordedConsumer RecordedEntity RecordedExchange RecordedExchangeBinding RecordedNamedEntity RecordedQueue RecordedQueueBinding RecoveryAwareAMQConnection AMQConnectionmodification that usesRecoveryAwareChannelNRecoveryAwareAMQConnectionFactory RecoveryAwareChannelManager RecoveryAwareChannelN ChannelNmodification that keeps track of delivery tags and avoids sendingRetryContext The context of a topology recovery retry operation.RetryResult The retry of a retried topology recovery operation.TopologyRecoveryRetryHandlerBuilder Builder to ease creation ofDefaultRetryHandlerinstances.TopologyRecoveryRetryLogic Useful ready-to-use conditions and operations forDefaultRetryHandler.