Class ListenerContainerFactoryConfigurer
- java.lang.Object
-
- org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer
-
public class ListenerContainerFactoryConfigurer extends java.lang.Object
Configures the providedConcurrentKafkaListenerContainerFactory
with aSeekToCurrentErrorHandler
, theDeadLetterPublishingRecoverer
created by theDeadLetterPublishingRecovererFactory
. Mind that the same factory can be used by many differentRetryableTopic
s but should not be shared with non retryable topics as some of their configurations will be overriden.- Since:
- 2.7
- Author:
- Tomaz Fernandes
-
-
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)
void
setContainerCustomizer(java.util.function.Consumer<ConcurrentMessageListenerContainer<?,?>> containerCustomizer)
void
setErrorHandlerCustomizer(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)
-
-