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

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

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)