Package org.springframework.kafka.annotation

Class RetryTopicConfigurationProvider

java.lang.Object

org.springframework.kafka.annotation.RetryTopicConfigurationProvider

public class RetryTopicConfigurationProvider
extends 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 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, Wang Zhiyang

See Also:

• RetryTopicConfigurer
• RetryableTopic
• DltHandler

Constructor Summary

Constructors

Constructor	Description
RetryTopicConfigurationProvider(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 Type	Method	Description
RetryTopicConfiguration	findRetryConfigurationFor(String[] topics, Method method, Class<?> clazz, Object bean)	Find retry topic configuration.
RetryTopicConfiguration	findRetryConfigurationFor(String[] topics, Method method, Object bean)

Methods inherited from class java.lang.Object

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

Constructor Details

RetryTopicConfigurationProvider

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

findRetryConfigurationFor

@Nullable
public RetryTopicConfiguration findRetryConfigurationFor(String[] topics,
 Method method,
 Object bean)

findRetryConfigurationFor

@Nullable
public RetryTopicConfiguration findRetryConfigurationFor(String[] topics,
 @Nullable
 Method method,
 @Nullable
 Class<?> clazz,
 Object bean)

Find retry topic configuration.

Parameters:

topics - the retryable topic list.

method - the method that gets @RetryableTopic annotation.

clazz - the class that gets @RetryableTopic annotation.

bean - the bean.

Returns:

the retry topic configuration.