Package org.springframework.kafka.retrytopic

Class EndpointCustomizerFactory

java.lang.Object

org.springframework.kafka.retrytopic.EndpointCustomizerFactory

public class EndpointCustomizerFactory
extends 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, BeanFactory beanFactory, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory)

Method Summary

Modifier and Type	Method	Description
protected EndpointCustomizer	addSuffixesAndMethod(DestinationTopic.Properties properties, Object bean, Method method)
final EndpointCustomizer	createEndpointCustomizer()
protected 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 Details

EndpointCustomizerFactory

public EndpointCustomizerFactory(DestinationTopic.Properties destinationProperties,
 EndpointHandlerMethod beanMethod,
 BeanFactory beanFactory,
 RetryTopicNamesProviderFactory retryTopicNamesProviderFactory)

Method Details

createEndpointCustomizer

public final EndpointCustomizer createEndpointCustomizer()

addSuffixesAndMethod

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

customizeAndRegisterTopics

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