パッケージ org.springframework.pulsar.listener
@NonNullApi @NonNullFields パッケージ org.springframework.pulsar.listener
Pulsar メッセージを受信するためのリスナーコンポーネントを含むパッケージ。
- クラス説明ack モードの列挙。手動承認の契約。
concurrencyに基づいてDefaultPulsarMessageListenerContainerインスタンスの同時実行コンテキストを作成します。PulsarConsumerErrorHandlerのデフォルト実装。PulsarMessageListenerContainerのデフォルト実装。メッセージリスナコンテナーを表すフレームワークによって使用される内部抽象化。メッセージを手動で確認するためのメッセージリスナー。手動確認を可能にするバッチメッセージリスナー。バッチメッセージリスナーは、エラーが発生した場合にこの例外をスローする必要があります。バッチメッセージリスナー。メッセージリスナーコンテナーを介したコンシューマーエラー処理の契約。リスナーコンテナーのランタイムプロパティが含まれています。失敗したレコードを DLT (Dead Letter Topic) に公開することでメッセージを回復できるPulsarMessageRecoverer実装。コンテナーのレジストリ。メッセージリスナコンテナーを表すフレームワークによって使用される内部抽象化。失敗した Pulsar メッセージを回復できるようにします。PulsarMessageRecovererの提供時のインターフェース。MessageListenerを単純に拡張した基本レコード MessageListener。