クラス AbstractKafkaBackOffManagerFactory
java.lang.ObjectSE
org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory
- 実装されたすべてのインターフェース:
Aware、ApplicationContextAware、KafkaBackOffManagerFactory
public abstract class AbstractKafkaBackOffManagerFactory
extends ObjectSE
implements KafkaBackOffManagerFactory, ApplicationContextAware
KafkaBackOffManagerFactory 実装の基本クラス。- 導入:
- 2.7
- 作成者:
- Tomaz Fernandes, Gary Russell
- 関連事項:
コンストラクターのサマリー
コンストラクターコンストラクター説明ApplicationContextからListenerContainerRegistryを取得するインスタンスを作成します。AbstractKafkaBackOffManagerFactory(ListenerContainerRegistry listenerContainerRegistry) 提供されたListenerContainerRegistryを使用してインスタンスを作成します。これは、MessageListenerContainerをフェッチしてバックオフするために使用されます。メソッドのサマリー
修飾子と型メソッド説明create()protected abstract KafkaConsumerBackoffManagerdoCreateManager(ListenerContainerRegistry registry) protected <T> Tprotected ListenerContainerRegistryfinal voidsetApplicationContext(ApplicationContext applicationContext) voidsetListenerContainerRegistry(ListenerContainerRegistry listenerContainerRegistry) MessageListenerContainerをフェッチしてバックオフするために使用されるListenerContainerRegistryを設定します。
コンストラクターの詳細
AbstractKafkaBackOffManagerFactory
public AbstractKafkaBackOffManagerFactory()ApplicationContextからListenerContainerRegistryを取得するインスタンスを作成します。AbstractKafkaBackOffManagerFactory
提供されたListenerContainerRegistryを使用してインスタンスを作成します。これは、MessageListenerContainerをフェッチしてバックオフするために使用されます。- パラメーター:
listenerContainerRegistry- 使用する listenerContainerRegistry。
メソッドの詳細
setListenerContainerRegistry
MessageListenerContainerをフェッチしてバックオフするために使用されるListenerContainerRegistryを設定します。- パラメーター:
listenerContainerRegistry- 使用する listenerContainerRegistry。
create
- 次で指定:
- インターフェース
KafkaBackOffManagerFactoryのcreate
doCreateManager
getListenerContainerRegistry
getBean
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAwareのsetApplicationContext