Class RetryableTopicAnnotationProcessor
- java.lang.Object
-
- org.springframework.kafka.annotation.RetryableTopicAnnotationProcessor
-
public class RetryableTopicAnnotationProcessor extends java.lang.Object
Processes the providedRetryableTopic
annotation returning anRetryTopicConfiguration
.- Since:
- 2.7
- Author:
- Tomaz Fernandes, Gary Russell
-
-
Constructor Summary
Constructors Constructor Description RetryableTopicAnnotationProcessor(org.springframework.beans.factory.BeanFactory beanFactory)
Construct an instance using the provided parameters and default resolver, expression context.RetryableTopicAnnotationProcessor(org.springframework.beans.factory.BeanFactory beanFactory, org.springframework.beans.factory.config.BeanExpressionResolver resolver, org.springframework.beans.factory.config.BeanExpressionContext expressionContext)
Construct an instance using the provided parameters.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RetryTopicConfiguration
processAnnotation(java.lang.String[] topics, java.lang.reflect.Method method, RetryableTopic annotation, java.lang.Object bean)
-
-
-
Constructor Detail
-
RetryableTopicAnnotationProcessor
public RetryableTopicAnnotationProcessor(org.springframework.beans.factory.BeanFactory beanFactory)
Construct an instance using the provided parameters and default resolver, expression context.- Parameters:
beanFactory
- the bean factory.
-
RetryableTopicAnnotationProcessor
public RetryableTopicAnnotationProcessor(org.springframework.beans.factory.BeanFactory beanFactory, org.springframework.beans.factory.config.BeanExpressionResolver resolver, org.springframework.beans.factory.config.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 Detail
-
processAnnotation
public RetryTopicConfiguration processAnnotation(java.lang.String[] topics, java.lang.reflect.Method method, RetryableTopic annotation, java.lang.Object bean)
-
-