Class ListenerContainerFactoryConfigurer
- java.lang.Object
-
- org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer
-
public class ListenerContainerFactoryConfigurer extends java.lang.ObjectConfigures the providedConcurrentKafkaListenerContainerFactorywith aSeekToCurrentErrorHandler, theDeadLetterPublishingRecoverercreated by theDeadLetterPublishingRecovererFactory. Mind that the same factory can be used by many differentRetryableTopics but should not be shared with non retryable topics as some of their configurations will be overriden.- Since:
- 2.7
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ConcurrentKafkaListenerContainerFactory<?,?>configure(ConcurrentKafkaListenerContainerFactory<?,?> containerFactory, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration)ConcurrentKafkaListenerContainerFactory<?,?>configureWithoutBackOffValues(ConcurrentKafkaListenerContainerFactory<?,?> containerFactory, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration)voidsetContainerCustomizer(java.util.function.Consumer<ConcurrentMessageListenerContainer<?,?>> containerCustomizer)voidsetErrorHandlerCustomizer(java.util.function.Consumer<ErrorHandler> errorHandlerCustomizer)
-
-
-
Method Detail
-
configure
public ConcurrentKafkaListenerContainerFactory<?,?> configure(ConcurrentKafkaListenerContainerFactory<?,?> containerFactory, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration)
-
configureWithoutBackOffValues
public ConcurrentKafkaListenerContainerFactory<?,?> configureWithoutBackOffValues(ConcurrentKafkaListenerContainerFactory<?,?> containerFactory, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration)
-
setContainerCustomizer
public void setContainerCustomizer(java.util.function.Consumer<ConcurrentMessageListenerContainer<?,?>> containerCustomizer)
-
setErrorHandlerCustomizer
public void setErrorHandlerCustomizer(java.util.function.Consumer<ErrorHandler> errorHandlerCustomizer)
-
-