Package org.springframework.kafka.retrytopic

Class ListenerContainerFactoryConfigurer

java.lang.Object

org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer

public class ListenerContainerFactoryConfigurer
extends java.lang.Object

Configures the provided ConcurrentKafkaListenerContainerFactory with a SeekToCurrentErrorHandler, the DeadLetterPublishingRecoverer created by the DeadLetterPublishingRecovererFactory. Mind that the same factory can be used by many different RetryableTopics 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

Modifier and Type	Method	Description
void	setContainerCustomizer(java.util.function.Consumer<ConcurrentMessageListenerContainer<?,?>> containerCustomizer)
void	setErrorHandlerCustomizer(java.util.function.Consumer<ErrorHandler> errorHandlerCustomizer)

Methods inherited from class java.lang.Object

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

Method Detail

setContainerCustomizer

public void setContainerCustomizer(java.util.function.Consumer<ConcurrentMessageListenerContainer<?,?>> containerCustomizer)

setErrorHandlerCustomizer

public void setErrorHandlerCustomizer(java.util.function.Consumer<ErrorHandler> errorHandlerCustomizer)