Package org.springframework.kafka.listener

Class AbstractKafkaBackOffManagerFactory

java.lang.Object

org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, KafkaBackOffManagerFactory

Direct Known Subclasses:

PartitionPausingBackOffManagerFactory

public abstract class AbstractKafkaBackOffManagerFactory
extends java.lang.Object
implements KafkaBackOffManagerFactory, org.springframework.context.ApplicationContextAware

Base class for KafkaBackOffManagerFactory implementations.

Since:

2.7

Author:

Tomaz Fernandes

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
protected void	addApplicationListener(org.springframework.context.ApplicationListener<?> applicationListener)
KafkaConsumerBackoffManager	create()
protected abstract KafkaConsumerBackoffManager	doCreateManager(ListenerContainerRegistry registry)
protected <T> T	getBean(java.lang.String beanName, java.lang.Class<T> beanClass)
protected ListenerContainerRegistry	getListenerContainerRegistry()
void	setApplicationContext(org.springframework.context.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 Detail

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.

AbstractKafkaBackOffManagerFactory

public AbstractKafkaBackOffManagerFactory()

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

Method Detail

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(java.lang.String beanName,
                        java.lang.Class<T> beanClass)

addApplicationListener

protected void addApplicationListener(org.springframework.context.ApplicationListener<?> applicationListener)

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware