Package org.springframework.kafka.retrytopic

Class RetryTopicConfigurer.EndpointProcessingCustomizerHolder

java.lang.Object

org.springframework.kafka.retrytopic.RetryTopicConfigurer.EndpointProcessingCustomizerHolder

Enclosing class:

RetryTopicConfigurer

public static final class RetryTopicConfigurer.EndpointProcessingCustomizerHolder
extends java.lang.Object

Creates the endpoint and factory customizers that will be called at the end of the KafkaListenerAnnotationBeanPostProcessor's processListener(MethodKafkaListenerEndpoint, KafkaListener, Object, Object, String)} method.

As a side effect, registers the topics in the DestinationTopicContainer.

Constructor Summary

Constructors

Constructor	Description
EndpointProcessingCustomizerHolder(java.util.function.Function<MethodKafkaListenerEndpoint<?,?>,MethodKafkaListenerEndpoint<?,?>> endpointCustomizer, java.util.function.Function<KafkaListenerContainerFactory<?>,KafkaListenerContainerFactory<?>> factoryCustomizer)

Method Summary

Modifier and Type	Method	Description
java.util.function.Function<MethodKafkaListenerEndpoint<?,?>,MethodKafkaListenerEndpoint<?,?>>	getEndpointCustomizer()
java.util.function.Function<KafkaListenerContainerFactory<?>,KafkaListenerContainerFactory<?>>	getFactoryCustomizer()

Methods inherited from class java.lang.Object

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

Constructor Detail

EndpointProcessingCustomizerHolder

public EndpointProcessingCustomizerHolder(java.util.function.Function<MethodKafkaListenerEndpoint<?,?>,MethodKafkaListenerEndpoint<?,?>> endpointCustomizer,
                                          java.util.function.Function<KafkaListenerContainerFactory<?>,KafkaListenerContainerFactory<?>> factoryCustomizer)

Method Detail

getEndpointCustomizer

public java.util.function.Function<MethodKafkaListenerEndpoint<?,?>,MethodKafkaListenerEndpoint<?,?>> getEndpointCustomizer()

getFactoryCustomizer

public java.util.function.Function<KafkaListenerContainerFactory<?>,KafkaListenerContainerFactory<?>> getFactoryCustomizer()