Uses of Interface
org.springframework.kafka.retrytopic.DestinationTopicProcessor
Packages that use DestinationTopicProcessor
-
Uses of DestinationTopicProcessor in org.springframework.kafka.retrytopic
Classes in org.springframework.kafka.retrytopic that implement DestinationTopicProcessorModifier and TypeClassDescriptionclass
Default implementation of theDestinationTopicProcessor
interface.Methods in org.springframework.kafka.retrytopic that return DestinationTopicProcessorModifier and TypeMethodDescriptionRetryTopicComponentFactory.destinationTopicProcessor
(DestinationTopicResolver destinationTopicResolver) Create theDestinationTopicProcessor
that will be used to process theDestinationTopic
instances and store them in the providedDestinationTopicResolver
.Methods in org.springframework.kafka.retrytopic with parameters of type DestinationTopicProcessorModifier and TypeMethodDescriptionRetryTopicComponentFactory.retryTopicConfigurer
(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, ListenerContainerFactoryResolver factoryResolver, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) Create theRetryTopicConfigurer
that will serve as an entry point for configuring non-blocking topic-based delayed retries for a givenKafkaListenerEndpoint
, by processing the appropriateRetryTopicConfiguration
.Constructors in org.springframework.kafka.retrytopic with parameters of type DestinationTopicProcessorModifierConstructorDescriptionRetryTopicConfigurer
(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryResolver containerFactoryResolver, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) Create an instance with the provided properties.