クラス ConsumerStoppedEvent
java.lang.ObjectSE
java.util.EventObjectSE
org.springframework.context.ApplicationEvent
org.springframework.kafka.event.KafkaEvent
org.springframework.kafka.event.ConsumerStoppedEvent
- 実装されたすべてのインターフェース:
SerializableSE
コンシューマーが停止したときに公開されるイベント。ステートレスリスナーを使用することをお勧めしますが、コンテキストイベントマルチキャストが非同期タスクを使用するように変更されていない限り、このイベントを使用してスレッドベースのリソースをクリーンアップできます(ThreadLocals の削除、スレッドスコープの Bean の破棄など)。エグゼキュータ。このイベントを使用して、トランザクションプロデューサーがフェンスされたために停止されたコンテナーを再起動することもできます。
- 導入:
- 2.2
- 作成者:
- Gary Russell
- 関連事項:
ネストされたクラスのサマリー
ネストされたクラスフィールドサマリー
クラス java.util.EventObjectSE から継承されたフィールド
sourceSE
コンストラクターのサマリー
コンストラクターコンストラクター説明ConsumerStoppedEvent
(ObjectSE source, ObjectSE container, ConsumerStoppedEvent.Reason reason) 提供されたソースとコンテナーでインスタンスを構築します。メソッドのサマリー
クラス org.springframework.kafka.event.KafkaEvent から継承されたメソッド
getContainer, getSource
クラス org.springframework.context.ApplicationEvent から継承されたメソッド
getTimestamp
クラス java.util.EventObjectSE から継承されたメソッド
getSource
コンストラクターの詳細
ConsumerStoppedEvent
public ConsumerStoppedEvent(ObjectSE source, ObjectSE container, ConsumerStoppedEvent.Reason reason) 提供されたソースとコンテナーでインスタンスを構築します。- パラメーター:
source
- イベントを生成したコンテナーインスタンス。container
- コンテナーまたはコンテナーが子の場合は親コンテナー。reason
- 理由。- 導入:
- 2.5.8
メソッドの詳細
getReason
コンシューマーが停止した理由を返します。- 戻り値:
- 理由。
- 導入:
- 2.5.8
toString
- オーバーライド:
- クラス
EventObjectSE
のtoString