Class RetryTopicConfigurationProvider
- java.lang.Object
-
- org.springframework.kafka.retrytopic.RetryTopicConfigurationProvider
-
public class RetryTopicConfigurationProvider extends java.lang.ObjectAttempts to provide an instance ofRetryTopicConfigurerby either creating one from aRetryableTopicannotation, or from the bean container if no annotation is available. If beans are found in the container there's a check to determine whether or not the provided topics topics should be handled by any of such instances. If the annotation is provided, aDltHandlerannotated method is looked up.- Since:
- 2.7
- Author:
- Tomaz Fernandes
- See Also:
RetryTopicConfigurer,RetryableTopic,DltHandler
-
-
Constructor Summary
Constructors Constructor Description RetryTopicConfigurationProvider(org.springframework.beans.factory.BeanFactory beanFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RetryTopicConfigurationfindRetryConfigurationFor(java.lang.String[] topics, java.lang.reflect.Method method, java.lang.Object bean)
-
-
-
Method Detail
-
findRetryConfigurationFor
public RetryTopicConfiguration findRetryConfigurationFor(java.lang.String[] topics, java.lang.reflect.Method method, java.lang.Object bean)
-
-