パッケージ org.springframework.amqp.rabbit.listener
@NonNullApi パッケージ org.springframework.amqp.rabbit.listener
メッセージリスナーコンテナーのクラスを提供します。
- クラス説明排他的コンシューマーの障害をログに記録するための
ConditionalExceptionLogger
のデフォルト実装。コンテナースレッドのError
SE のハンドラー。このコンテナーの共有 Rabbit 接続の初期セットアップが失敗したことを示す例外。Throwable
SE をラップする実行時例外。Rabbit リスナーエンドポイントの基本モデル。コンシューマーが再起動されるたびに発行されるイベント。新しいコンシューマーが開始されるたびに公開されるイベント。コンシューマーが停止する (再起動しない) たびに発行されるイベント。ブローカー接続の知識をカプセル化し、独自のライフサイクル (開始と停止) を持つ特殊なコンシューマー。構成された拒否戦略により、メッセージが致命的であり、再キューイングされるべきではないと判断された場合に、条件付きで例外をAmqpRejectAndDontRequeueException
にラップするErrorHandler
。FatalExceptionStrategy
のデフォルト実装。コンシューマーがキューにサブスクライブするときに、リスナーコンテナーによって発行されるAmqpEvent
。SimpleMessageListenerContainer
はそれほど単純ではありません。Direct ReplyTo のリスナーコンテナーは、疑似キューAddress.AMQ_RABBITMQ_REPLY_TO
のみをリッスンします。チャネルのホルダー。再利用のために割り当てられた後、コンシューマーの不適切なリリースを防ぐために使用されるコンシューマーエポックが含まれます。ConditionalRejectingErrorHandler
が例外を致命的と見なし、メッセージを再キューイングしないかどうかを決定するための戦略インターフェース。リスナーコンシューマーが失敗したときに発行されます。リスナーコンシューマーが終了したときに発行されます。コンテナーがアイドル状態になるように構成されている場合に、コンテナーがアイドル状態のときに発生するイベント。リスナー例外がListenerExecutionFailedException
でラップされることを認識しているRuleBasedTransactionAttribute
のサブクラス。AcknowledgeMode.AUTO
使用時のメッセージ ack のリスナー。メッセージリスナコンテナーを表すフレームワークによって使用される内部抽象化。このエンドポイントの受信メッセージを処理するために呼び出すメソッドを提供するRabbitListenerEndpoint
。リスナーアダプターのプロバイダー。Micrometer への厳密な参照を避けるための抽象化。不足しているキューが検出されたときに発行されるイベント。この例外は、リッスンできるキューがないため、コンシューマーを開始できなかったことを示します。MessageListenerContainer
のファクトリ。Rabbit リスナーエンドポイントのモデル。RabbitListenerEndpoint
をRabbitListenerEndpointRegistry
に登録するためのヘルパー Bean。登録されたエンドポイントに必要なMessageListenerContainer
インスタンスを作成します。