Package for retryable topic handling.
ClassDescriptionGenerates the backoff values from the provided maxAttempts value and
BackOffPolicy.Implement this interface to create each
DeadLetterPublishingRecoverer.Default implementation of the
DestinationTopicProcessorinterface.Default implementation of the
DestinationTopicResolverinterface.Representation of a Destination Topic to which messages can be forwarded, such as retry topics and dlt.Provides methods to store and retrieve
DestinationTopicinstances.Creates a list of
DestinationTopic.Propertiesbased on the provided configurations.Provides methods for resolving the destination to which a message that failed to be processed should be forwarded to.Strategies for handling DLT processing.Customizes main, retry and DLT endpoints in the Retry Topic functionality and returns the resulting topic names.The bean names for the non-blocking topic-based delayed retries feature.Provide the component instances that will be used with
RetryTopicConfigurationSupport.Contains the provided configuration for the retryable topics.Builder class to create
RetryTopicConfigurationinstances.This is the main class providing the configuration behind the non-blocking, topic-based delayed retries feature.Configure blocking retries to be used along non-blocking.Configure customizers for components instantiated by the retry topics feature.Configures main, retry and DLT topics based on a main endpoint and provided configurations to accomplish a distributed retry / DLT pattern in a non-blocking fashion, at the expense of ordering guarantees.Constants for the RetryTopic functionality.Contains the headers that will be used in the forwarded messages.Handles the naming related to the retry and dead letter topics.A wrapper class for a
TaskSchedulerto use for scheduling container resumption when a partition has been paused for a retry topic.Strategy for topic reuse when multiple, sequential retries have the same backoff interval.Retry and dead letter naming handling that add a suffix to each name.Constants for the RetryTopic functionality.