Package org.springframework.kafka.retrytopic

Class RetryableTopicAnnotationProcessor

java.lang.Object

org.springframework.kafka.retrytopic.RetryableTopicAnnotationProcessor

public class RetryableTopicAnnotationProcessor
extends java.lang.Object

Processes the provided RetryableTopic annotation returning an RetryTopicConfiguration.

Since:

2.7

Author:

Tomaz Fernandes

Constructor Summary

Constructors

Constructor	Description
RetryableTopicAnnotationProcessor(org.springframework.beans.factory.BeanFactory beanFactory)

Method Summary

Modifier and Type	Method	Description
RetryTopicConfiguration	processAnnotation(java.lang.String[] topics, java.lang.reflect.Method method, RetryableTopic annotation, java.lang.Object bean)

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryableTopicAnnotationProcessor

public RetryableTopicAnnotationProcessor(org.springframework.beans.factory.BeanFactory beanFactory)

Method Detail

processAnnotation

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