Package org.springframework.kafka.annotation

Class RetryableTopicAnnotationProcessor

java.lang.Object

org.springframework.kafka.annotation.RetryableTopicAnnotationProcessor

public class RetryableTopicAnnotationProcessor
extends Object

Processes the provided RetryableTopic annotation returning an RetryTopicConfiguration.

Since:

2.7

Author:

Tomaz Fernandes, Gary Russell, Adrian Chlebosz, Wang Zhiyang

Constructor Summary

Constructors

Constructor	Description
RetryableTopicAnnotationProcessor(BeanFactory beanFactory)	Construct an instance using the provided parameters and default resolver, expression context.
RetryableTopicAnnotationProcessor(BeanFactory beanFactory, BeanExpressionResolver resolver, BeanExpressionContext expressionContext)	Construct an instance using the provided parameters.

Method Summary

Modifier and Type	Method	Description
RetryTopicConfiguration	processAnnotation(String[] topics, Class<?> clazz, RetryableTopic annotation, Object bean)
RetryTopicConfiguration	processAnnotation(String[] topics, Method method, RetryableTopic annotation, Object bean)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RetryableTopicAnnotationProcessor

public RetryableTopicAnnotationProcessor(BeanFactory beanFactory)

Construct an instance using the provided parameters and default resolver, expression context.

Parameters:

beanFactory - the bean factory.

RetryableTopicAnnotationProcessor

public RetryableTopicAnnotationProcessor(@Nullable
 BeanFactory beanFactory,
 @Nullable
 BeanExpressionResolver resolver,
 @Nullable
 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

processAnnotation

public RetryTopicConfiguration processAnnotation(String[] topics,
 Method method,
 RetryableTopic annotation,
 Object bean)

processAnnotation

public RetryTopicConfiguration processAnnotation(String[] topics,
 Class<?> clazz,
 RetryableTopic annotation,
 Object bean)