Class RetryTopicConfigurationProvider
java.lang.Object
org.springframework.kafka.annotation.RetryTopicConfigurationProvider
Attempts to provide an instance of
RetryTopicConfiguration
by either creating
one from a RetryableTopic
annotation, 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, a
DltHandler
annotated method is looked up.- Since:
- 2.7
- Author:
- Tomaz Fernandes, Gary Russell
- See Also:
-
Constructor Summary
ConstructorDescriptionRetryTopicConfigurationProvider
(BeanFactory beanFactory) Construct an instance using the provided bean factory and default resolver and bean expression context.RetryTopicConfigurationProvider
(BeanFactory beanFactory, BeanExpressionResolver resolver, BeanExpressionContext expressionContext) Construct an instance using the provided parameters. -
Method Summary
Modifier and TypeMethodDescriptionfindRetryConfigurationFor
(String[] topics, Method method, Object bean)
-
Constructor Details
-
RetryTopicConfigurationProvider
Construct an instance using the provided bean factory and default resolver and bean expression context.- Parameters:
beanFactory
- the bean factory.
-
RetryTopicConfigurationProvider
public RetryTopicConfigurationProvider(BeanFactory beanFactory, BeanExpressionResolver resolver, BeanExpressionContext expressionContext) Construct an instance using the provided parameters.- Parameters:
beanFactory
- the bean factory.resolver
- the bean expression resolver.expressionContext
- the bean expression context.
-
-
Method Details
-
findRetryConfigurationFor
public RetryTopicConfiguration findRetryConfigurationFor(String[] topics, Method method, Object bean)
-