Implementation of connection and topology recovery.
Interface Summary Interface Description BackoffPolicyBackoff policy for topology recovery retry attempts. ConsumerRecoveryListenerNot part of the public API. QueueRecoveryListenerNot part of the public API. RecoveryCanBeginListenerUsed internally to indicate when connection recovery can begin. RetryHandlerContract to retry failed operations during topology recovery. TopologyRecoveryFilterFilter to know whether entities should be recovered or not.
Class Summary Class Description AutorecoveringChannel
Channelimplementation that is automatically recovered during connection recovery.
AutorecoveringConnectionConnection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e.g. DefaultRetryHandlerComposable topology recovery retry handler. DefaultRetryHandler.RetryCondition<E extends RecordedEntity> DefaultRetryHandler.RetryOperation<T> RecordedBinding RecordedConsumer RecordedEntity RecordedExchange RecordedExchangeBinding RecordedNamedEntity RecordedQueue RecordedQueueBinding RecoveryAwareAMQConnection RecoveryAwareAMQConnectionFactory RecoveryAwareChannelManager RecoveryAwareChannelN
ChannelNmodification that keeps track of delivery tags and avoids sending
RetryContextThe context of a topology recovery retry operation. RetryResultThe retry of a retried topology recovery operation. TopologyRecoveryRetryHandlerBuilderBuilder to ease creation of
TopologyRecoveryRetryLogicUseful ready-to-use conditions and operations for