Package org.springframework.kafka.annotation

Class RetryTopicConfigurationProvider

java.lang.Object

org.springframework.kafka.annotation.RetryTopicConfigurationProvider

public class RetryTopicConfigurationProvider
extends java.lang.Object

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:

RetryTopicConfigurer, RetryableTopic, DltHandler

Constructor Summary

Constructors

Constructor	Description
RetryTopicConfigurationProvider(org.springframework.beans.factory.BeanFactory beanFactory)	Construct an instance using the provided bean factory and default resolver and bean expression context.
RetryTopicConfigurationProvider(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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryTopicConfigurationProvider

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

Construct an instance using the provided bean factory and default resolver and bean expression context.

Parameters:

beanFactory - the bean factory.

RetryTopicConfigurationProvider

public RetryTopicConfigurationProvider(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

findRetryConfigurationFor

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