| BackOffValuesGenerator |
Generates the backoff values from the provided maxAttempts value and
BackOffPolicy.
|
| DeadLetterPublishingRecovererFactory |
|
| DeadLetterPublishingRecovererFactory.Configuration |
|
| ListenerContainerFactoryConfigurer |
|
| ListenerContainerFactoryResolver |
|
| RetryableTopicAnnotationProcessor |
|
| RetryTopicBootstrapper |
Bootstraps the RetryTopicConfigurer context, registering the dependency
beans and configuring the ApplicationListeners.
|
| RetryTopicConfiguration |
Contains the provided configuration for the retryable topics.
|
| RetryTopicConfigurationBuilder |
|
| RetryTopicConfigurationProvider |
Attempts to provide an instance of RetryTopicConfigurer by either creating one
from a RetryableTopic annotation, or from the bean container if no annotation
is available.
|
| RetryTopicConfigurer |
Configures main, retry and DLT topics based on a main endpoint and provided
configurations to acomplish a distributed retry / DLT pattern in a non-blocking
fashion, at the expense of ordering guarantees.
|
| RetryTopicConfigurer.EndpointProcessingCustomizerHolder |
Creates the endpoint and factory customizers that will be called at the end of the
KafkaListenerAnnotationBeanPostProcessor's processListener(MethodKafkaListenerEndpoint, KafkaListener, Object, Object, String)}
method.
|
| RetryTopicConstants |
Constants for the RetryTopic functionality.
|
| RetryTopicHeaders |
Contains the headers that will be used in the forwarded messages.
|
| RetryTopicInternalBeanNames |
Contains the internal bean names that will be used by the retryable topic configuration.
|