Package org.springframework.kafka.retrytopic

Class EndpointCustomizerFactory

java.lang.Object

org.springframework.kafka.retrytopic.EndpointCustomizerFactory

public class EndpointCustomizerFactory
extends java.lang.Object

Creates the EndpointCustomizer that will be used by the RetryTopicConfigurer to customize the main, retry and DLT endpoints.

Since:

2.7.2

Author:

Tomaz Fernandes, Gary Russell

See Also:

RetryTopicConfigurer, DestinationTopic.Properties, RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Constructor Summary

Constructors

Constructor	Description
EndpointCustomizerFactory(DestinationTopic.Properties destinationProperties, EndpointHandlerMethod beanMethod, org.springframework.beans.factory.BeanFactory beanFactory, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory)

Method Summary

Modifier and Type	Method	Description
protected EndpointCustomizer	addSuffixesAndMethod(DestinationTopic.Properties properties, java.lang.Object bean, java.lang.reflect.Method method)
EndpointCustomizer	createEndpointCustomizer()
protected java.util.Collection<EndpointCustomizer.TopicNamesHolder>	customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider, MethodKafkaListenerEndpoint<?,?> endpoint)

Methods inherited from class java.lang.Object

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

Constructor Detail

EndpointCustomizerFactory

public EndpointCustomizerFactory(DestinationTopic.Properties destinationProperties,
                                 EndpointHandlerMethod beanMethod,
                                 org.springframework.beans.factory.BeanFactory beanFactory,
                                 RetryTopicNamesProviderFactory retryTopicNamesProviderFactory)

Method Detail

createEndpointCustomizer

public final EndpointCustomizer createEndpointCustomizer()

addSuffixesAndMethod

protected EndpointCustomizer addSuffixesAndMethod(DestinationTopic.Properties properties,
                                                  java.lang.Object bean,
                                                  java.lang.reflect.Method method)

customizeAndRegisterTopics

protected java.util.Collection<EndpointCustomizer.TopicNamesHolder> customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider,
                                                                                               MethodKafkaListenerEndpoint<?,?> endpoint)