Package org.springframework.kafka.listener

Class AbstractKafkaBackOffManagerFactory

java.lang.Object

org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory

All Implemented Interfaces:

Aware, ApplicationContextAware, KafkaBackOffManagerFactory

Direct Known Subclasses:

ContainerPartitionPausingBackOffManagerFactory

public abstract class AbstractKafkaBackOffManagerFactory
extends Object
implements KafkaBackOffManagerFactory, ApplicationContextAware

Base class for KafkaBackOffManagerFactory implementations.

Since:

2.7

Author:

Tomaz Fernandes, Gary Russell

See Also:

• KafkaConsumerBackoffManager

Constructor Summary

Constructors

Constructor	Description
AbstractKafkaBackOffManagerFactory()	Creates an instance that will retrieve the ListenerContainerRegistry from the ApplicationContext.
AbstractKafkaBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry)	Creates an instance with the provided ListenerContainerRegistry, which will be used to fetch the MessageListenerContainer to back off.

Method Summary

Modifier and Type	Method	Description
KafkaConsumerBackoffManager	create()
protected abstract KafkaConsumerBackoffManager	doCreateManager(ListenerContainerRegistry registry)
protected <T> T	getBean(String beanName, Class<T> beanClass)
protected ListenerContainerRegistry	getListenerContainerRegistry()
final void	setApplicationContext(ApplicationContext applicationContext)
void	setListenerContainerRegistry(ListenerContainerRegistry listenerContainerRegistry)	Sets the ListenerContainerRegistry, that will be used to fetch the MessageListenerContainer to back off.

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractKafkaBackOffManagerFactory

public AbstractKafkaBackOffManagerFactory()

Creates an instance that will retrieve the ListenerContainerRegistry from the ApplicationContext.

AbstractKafkaBackOffManagerFactory

public AbstractKafkaBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry)

Creates an instance with the provided ListenerContainerRegistry, which will be used to fetch the MessageListenerContainer to back off.

Parameters:

listenerContainerRegistry - the listenerContainerRegistry to use.

Method Details

setListenerContainerRegistry

public void setListenerContainerRegistry(ListenerContainerRegistry listenerContainerRegistry)

Sets the ListenerContainerRegistry, that will be used to fetch the MessageListenerContainer to back off.

Parameters:

listenerContainerRegistry - the listenerContainerRegistry to use.

create

public KafkaConsumerBackoffManager create()

Specified by:

create in interface KafkaBackOffManagerFactory

doCreateManager

protected abstract KafkaConsumerBackoffManager doCreateManager(ListenerContainerRegistry registry)

getListenerContainerRegistry

protected ListenerContainerRegistry getListenerContainerRegistry()

getBean

protected <T> T getBean(String beanName,
 Class<T> beanClass)

setApplicationContext

public final void setApplicationContext(ApplicationContext applicationContext)

Specified by:

setApplicationContext in interface ApplicationContextAware