すべてのクラスとインターフェース
クラス
説明
Message のペイロードを抽出するために必要なインフラストラクチャを提供する抽象 MessageListener アダプター。 応答式評価のルートオブジェクト。
引数をサポートするビルダーの基本クラス。
メッセージ本文を圧縮するポストプロセッサーの基本クラス。
アドレスのシャッフルに使用されるモード。
チャネルクローズ例外をログに記録するための
ConditionalExceptionLogger のデフォルト実装。Declarable クラスの基本クラス。MessageProperties.SPRING_AUTO_DECOMPRESS ヘッダーが true の場合にメッセージ本文を解凍する、またはコンテンツエンコーディングが AbstractDecompressingPostProcessor.getEncoding() と一致する場合、または AbstractDecompressingPostProcessor.getEncoding() + ":" で始まる場合にオプションで常に解凍する、ポストプロセッサーの基本クラス。この場合、コロンに続くエンコーディングが解凍されたメッセージの最終的なコンテンツエンコーディングになります。DeflaterSE に基づくポストプロセッサーの基本クラス。 すべての交換型を説明する共通のプロパティ。
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
抽象的な Jackson 3 メッセージコンバーター。
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、Jackson 3 では
DefaultJacksonJavaTypeMapper が優先されます。MessageConverter 実装の便利な基本クラス。 排他的コンシューマーの障害をログに記録するための
ConditionalExceptionLogger のデフォルト実装。 コンテナースレッドの
ErrorSE のハンドラー。 このコンテナーの共有 Rabbit 接続の初期セットアップが失敗したことを示す例外。
ThrowableSE をラップする実行時例外。Spring の基本コンテナー実装の
RabbitListenerContainerFactory。Rabbit リスナーエンドポイントの基本モデル。
インターセプターファクトリの便利な基本クラス。
ルックアップキーに基づいて
AbstractRoutingConnectionFactory.createConnection() 呼び出しをさまざまなターゲット ConnectionFactories のいずれかにルーティングする抽象 ConnectionFactory 実装。 リスナーコンテナーでサポートされる確認モード。
アクティブなオブジェクトを追跡するメカニズム。
AMQP メッセージのパブリケーションのアドレスを表します。
プライマリトランザクションが完了した後に afterCompletion を実行するときにコミットまたはロールバックに失敗したことを示します。
Java デシリアライゼーションを潜在的に使用する MessageConverters。
確認応答の抽象化。
AMQP > 0.9 の移植可能な AMQP 管理操作の基本セットを指定します。
ロギングイベントを AMQP Exchange に発行する Log4j 2 アペンダー。
ロギングイベントを AMQP Exchange に発行する Logback アペンダー。
アペンダーのマネージャークラス。
LoggingEvent、その MDC プロパティ、および再試行回数をカプセル化するヘルパークラス。
LoggingEvent、その MDC プロパティ、および再試行回数をカプセル化する小さなヘルパークラス。
コンテキストのクローズ中に接続ファクトリが破棄された場合にスローされます。ファクトリは接続を開くことができなくなります。
認証例外のランタイムラッパー。
リモートプロセスが終了した場合、またはネットワークの課題がある場合に、AMQP 操作から一般的にスローされる可能性がある
ConnectExceptionSE の RuntimeException ラッパー。RabbitMQ AMQP 1.0
Connection 管理の契約。 イベントの基本クラス。
AMQP 操作の実行時に発生するエラーのベース RuntimeException。
メッセージングメッセージヘッダーを送信
MessageProperties にマッピングするための戦略インターフェース (例:Message ヘッダーとの間で AMQP MessageProperties を設定および / または取得するために使用される定義済みの名前とプレフィックス。IllegalStateException と同等ですが、AmqpException 階層内にあります。
AMQP 操作から一般的にスローできる
IOExceptionSE の RuntimeException ラッパー。Spring AMQP 要件に対する
DefaultMessageHandlerMethodFactory の拡張。AMQP 固有のヘッダーへのアクセスを提供する
MessageHeaderAccessor 実装。 必須フラグが設定されているときにリクエストメッセージを配信できない場合にスローされる例外。
メッセージの公開後に否定応答を受信した場合にスローされる例外。
DLQ などの機能を有効にするために、
basic.reject が requeue=false とともに送信されることを示すために使用されるリスナー実装の例外。 リクエスト / 応答シナリオでサーバーによってスローされた例外をラップする例外。
非同期応答タイムアウト。
一部のリソースにアクセスできない場合にスローされる
AmqpException。AMQP 操作の基本セットを指定します。
時間制限のある操作が目的の時間内に実行されなかった場合にスローされる例外。
AMQP 操作でサポートされていないエンコードの RuntimeException。
匿名、非永続、排他的、自動削除キューを表します。
QueueBinding 内でキューなどを宣言するときに使用される引数を表します。 引数マップのビルダー。
このインターフェースを実装するクラスは、
CompletableFutureSE を使用して非同期の送受信操作を実行できます。 コンシューマーが再起動されるたびに発行されるイベント。
新しいコンシューマーが開始されるたびに公開されるイベント。
コンシューマーが停止する (再起動しない) たびに発行されるイベント。
CompletableFutureSE を返す非同期の送受信操作を提供し、呼び出し元が後で get() またはコールバックを使用して応答を取得できるようにします。 接続が現在開かれておらず、回復中の自動回復接続である場合にスローされる例外。
デフォルトでは "prefix" が "spring.gen-" である形式の
<prefix><base64url> で名前を生成します (例: ジェネリクスサポート用の
AbstractBuilder 拡張。 リスナーコンテナーファクトリの基本抽象クラス。
個々のメッセージをより大きなメッセージにまとめることを許可する
RabbitTemplate。 メッセージをバッチ処理するための戦略。
コンテナーがサポートしている場合、メッセージのバッチを受信するために使用されます。
バッチリスナー用のリスナーアダプター。
バインディングを記述するための情報を収集する単純なコンテナー。
バインド先。
コードベースの構成でより流れるような API スタイルのバインディングを作成するための基本的なビルダークラス。
一般的な宛先設定者。
直接交換ルーティングキーコンフィギュアラー。
ジェネリクス引数設定ツール。
汎用交換ルーティングキーコンフィギュアラー。
ヘッダー交換設定者。
トピック交換ルーティングキーコンフィギュアラー。
ブローカー接続の知識をカプセル化し、独自のライフサイクル (開始と停止) を持つ特殊なコンシューマー。
イベント交換プラグインによって生成されたブローカーイベントを表します。
イベント交換プラグインが有効な場合、この型のオブジェクトが Bean として宣言されると、選択されたイベントは
BrokerEvent として公開されます。 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、JUnit 5
RabbitAvailable が優先されます。Rabbit ブローカーアプリケーションが実行されていないかアクセスできない場合に統合テストが失敗するのを防ぐために使用できるクラス。
指定されたホストポートでブローカーが使用できない場合にスローされる
RuntimeExceptionSE。 すべての統合テスト用のグローバルコンビニエンスクラス。ブローカーのセットアップ用の定数やその他のユーティリティを保持します。
(キャッシュモードが
CachingConnectionFactory.CacheMode.CHANNEL (デフォルト) の場合、すべての CachingConnectionFactory.createConnection() 呼び出しから同じ接続を返し、Connection.close() への呼び出しを無視して Channel をキャッシュする ConnectionFactory 実装。 キャッシュモード。
パブリッシャーの型は、使用を確認します。
コンテナーがサポートしている場合、メッセージのバッチを受信するために使用されます。
メッセージが受信されたチャネルを認識しているメッセージリスナー。
RabbitTemplate で使用する基本的なコールバック。
新しいチャネルの作成と破棄のリスナー。
チャネルプロキシによって実装される
Channel のサブインターフェース。 メッセージの受信時にインスタンス化する必要があるクラスを作成できるように、メッセージにメタデータを設定するための戦略。
孤立したコンシューマーを回避するために、回復されたチャネルを閉じる
RecoveryListener。 デリゲートを順番に呼び出す複合リスナー。
複数のカスタマイザーの構成を同時に提供する
ContainerCustomizer の実装。 特定のイベントのロギングのカスタマイズをサポートするコンポーネントの場合、ユーザーはこのインターフェースの実装を提供して、既存のロギング動作を変更できます。
構成された拒否戦略により、メッセージが致命的であり、再キューイングされるべきではないと判断された場合に、条件付きで例外を
AmqpRejectAndDontRequeueException にラップする ErrorHandler。FatalExceptionStrategy のデフォルト実装。 接続がブロックされたときに
CachingConnectionFactory によって発行される AmqpEvent。Connections を作成するためのインターフェースベースの ConnectionFactory。 接続ファクトリを構成するためのユーティリティメソッド。
命令の実行時に
ConnectionFactory コンテキストのバインドとバインド解除を処理するヘルパークラス。Spring ベースの Rabbit
ConnectionFactory を管理するためのヘルパークラス。特に、特定の ConnectionFactory のトランザクション Rabbit リソースを取得するためのものです。 リソース作成用のコールバックインターフェース。
接続の作成と終了のリスナー。
アプリケーション固有の接続名を作成する戦略。RabbitMQ サーバーがサポートしている場合、管理 UI に表示できます。
接続プロキシによって実装される
Connection のサブインターフェース。 接続のブロックが解除されたときに
CachingConnectionFactory によって発行される AmqpEvent。 一貫性ハッシュ交換型の
AbstractExchange 拡張。 コンシューマーがキューにサブスクライブするときに、リスナーコンテナーによって発行される
AmqpEvent。 ブロッキング受信操作が実行されましたが、受信タイムアウト前に consumeOk が受信されなかった場合にスローされます。
ブローカーがコンシューマーをキャンセルし、メッセージキューが空になったときにスローされます。
コンシューマーは、プライマリチャネルをこのクラスに登録します。
ConsumerBuilder のカスタマイザー。basicConsume 操作を発行するときに使用するコンシューマータグを決定するための戦略インターフェース。 コンテナーが作成および設定された後、コンテナーファクトリによって呼び出されます。
リスナーコンテナーのユーティリティメソッド。
contentType ヘッダーに基づいて実際の
MessageConverter に委譲する複合 MessageConverter。 型
Continuation のメソッド引数の何もしないリゾルバー。 送信されたメッセージに関する情報を関連付けるために使用されるデータのマーカーインターフェース。
パブリッシャーの確認を送信済みメッセージに関連付けるための基本クラス。
発行元の確認を表します。
パブリッシャーが確認する相関データを更新、置換、作成するために、メッセージをパブリッシュする直前に呼び出されるコールバック。
カスタム交換を説明するための情報を収集する単純なコンテナー。
このインターフェースを実装するクラスは、
AmqpAdmin によるコンテキストの初期化中にブローカーで自動宣言できます。 この型の Bean は、
Declarable を宣言する前に AmqpAdmin によって呼び出され、そのカスタマイズを可能にします。Declarable オブジェクトのコレクション。コレクションに対して単一の Bean 宣言を使用して、ブローカーで複数のオブジェクトを宣言するために使用されます。 宣言例外が発生したときに発行されるアプリケーションイベント。
接続が確立されたときに単一の交換を宣言する
ConnectionListener。MessageProperties の型情報を使用して、JSON との間でマップします。型を含むメッセージプロパティのデフォルト名は "__TypeId__" です。 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、Jackson 3 では
DefaultJacksonJavaTypeMapper が優先されます。Jackson 3 型のマッパー。
MessagePropertiesConverter 戦略のデフォルト実装。 デフォルト
StreamMessageConverter。DeflaterOutputStreamSE を使用してメッセージ本文を圧縮するポストプロセッサー。 コンテンツのエンコーディングに応じて、その
MessagePostProcessor の 1 つに委譲する MessagePostProcessor。 メッセージペイロード型に基づいて
InvocableHandlerMethod に委譲します。 任意のメッセージをカプセル化します - シンプルな "Bean" ホルダー構造。
直接交換を説明するための情報を収集する単純なコンテナー。
SimpleMessageListenerContainer はそれほど単純ではありません。 通常の
DirectMessageListenerContainer を構築するための RabbitListenerContainerFactory 実装。Direct ReplyTo のリスナーコンテナーは、疑似キュー
Address.AMQ_RABBITMQ_REPLY_TO のみをリッスンします。 チャネルのホルダー。再利用のために割り当てられた後、コンシューマーの不適切なリリースを防ぐために使用されるコンシューマーエポックが含まれます。
RabbitListenerContainerFactory によって隠れて作成される Rabbit リスナーアノテーション付きエンドポイントを有効にします。 すべての取引所のインターフェース。
RabbitListener キューをバインドする交換。Exchange を構築するための流れるような API を提供するビルダー。 標準の Exchange 型名の定数。
Expression インスタンスを作成するための FactoryBean。
提供された情報を使用して接続ファクトリを決定するためのコールバック。
ファンアウト交換を説明するための情報を収集する単純なコンテナー。
ConditionalRejectingErrorHandler が例外を致命的と見なし、メッセージを再キューイングしないかどうかを決定するための戦略インターフェース。 リスナーメソッドの実行が回復不能な問題で失敗した場合にスローされる例外。
起動時にリスナーメソッドの実行が失敗した場合にスローされる例外。
GZIPInputStreamSE を使用してメッセージ本文を解凍するポストプロセッサー。GZIPOutputStreamSE を使用してメッセージ本文を圧縮するポストプロセッサー。InvocableHandlerMethod または DelegatingInvocableHandler のラッパー。 ヘッダー交換。
メッセージの現在のバッチをすぐに確認する必要があることを通知するリスナー実装の特別な例外 (つまり
リスナーからスローされる特別な
AmqpException (例:ImmediateRequeueAmqpException をスローする MessageRecoverer 実装は、リスナーコンテナーでの後続の再キューイングのために使用されます。InflaterInputStreamSE を使用してメッセージ本文を解凍するポストプロセッサー。 リスナーメソッド呼び出しの結果。
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、Jackson 3 では
JacksonJavaTypeMapper が優先されます。 型変換の優先順位 - メソッドパラメーターまたはメッセージヘッダーから推測されます。
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、Jackson 3 では
JacksonJsonMessageConverter が優先されます。 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、Jackson 3 では
JacksonXmlMessageConverter が優先されます。 メッセージの受信時にインスタンス化する必要があるクラスを作成できるように、メッセージにメタデータを設定するための戦略。
型変換の優先順位 - メソッドパラメーターまたはメッセージヘッダーから推測されます。
Jackson 3 を使用する JSON コンバーター。
Spring Data
ProjectionFactory を使用して、受信メッセージを射影 インターフェースにバインドします。 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、ネイティブの Jackson 3
JsonMapper.builder() API が優先されます。Jackson 3 XML マッパーを使用する XML コンバーター。
一部の Java 反復コードを単純化するための連鎖ユーティリティメソッド。
JUnit のルールと条件のユーティリティメソッド。
Kotlin
suspend 機能をサポートするための InvocableHandlerMethod 拡張。 オプションで実際のメソッドを呼び出し、カスタム結果を返すことができる
Answer。 実メソッドを呼び出してラッチをカウントダウンする void を返すメソッドの
Answer。 このインターフェースも実装する
MessageListener は、初期化中に構成を検証することができます。 リスナーコンシューマーが失敗したときに発行されます。
リスナーコンシューマーが終了したときに発行されます。
リスナーコンテナーを作成するためのファクトリ Bean。
コンテナーの種類。
コンテナーがアイドル状態になるように構成されている場合に、コンテナーがアイドル状態のときに発生するイベント。
リスナーメソッドの実行が失敗したときにスローされる例外。
リスナー例外が
ListenerExecutionFailedException でラップされることを認識している RuleBasedTransactionAttribute のサブクラス。 キューが配置されているノードを決定し、そのノードに直接接続するファクトリを返す
RoutingConnectionFactory。 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、JUnit 5
LogLevels が優先されます。 これでアノテーションが付けられたテストクラスは、テスト間でログレベルを変更します。
各テストの前後にログレベルを調整および元に戻す JUnit 条件。
環境変数またはシステムプロパティ (デフォルト
RUN_LONG_INTEGRATION_TESTS) が存在しない場合、または Boolean.parseBoolean(String)SE が true に評価する値を持たない場合、これでアノテーションが付けられたテストクラスは実行されません。 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、JUnit 5
LongRunning が優先されます。ExecutionCondition は、環境変数またはプロパティが設定されていない限り、長時間実行されるテストをスキップします。MapSE の Builder パターン実装。0-8 および 0-9-1 AMQP 仕様は、メッセージクラスまたはインターフェースを定義しません。
AcknowledgeMode.AUTO 使用時のメッセージ ack のリスナー。 メッセージのバッチ、交換、ルーティングキーを含む
Message をカプセル化するオブジェクト。 バッチリスナーで使用するリトライリカバリ。
流れるような API を使用して、byte[] 本体または別のメッセージから Spring AMQP メッセージを構築します。
Message および MessageProperties 流れるような API を構築するためのサポートクラス。 メッセージまたはオブジェクトの変換で問題が発生した場合に、メッセージコンバーターによってスローされる例外。
メッセージコンバーターインターフェース。
メッセージ配信モードの列挙。
Amqp メッセージの非同期配信を受信するためのリスナーインターフェース。
柔軟なメッセージ型変換により、リフレクションを介してターゲットリスナーメソッドにメッセージの処理を委譲するメッセージリスナーアダプター。
メッセージリスナコンテナーを表すフレームワークによって使用される内部抽象化。
メッセージ変換が実行された後にヘッダーまたはプロパティを追加 / 変更するために使用できる
AmqpTemplate#convertAndSend(Object, MessagePostProcessor) など、フレームワークのいくつかの場所で使用されます。 メッセージポストプロセッサーのユーティリティ。
AMQP メッセージのメッセージプロパティ。
流れるような API を使用して Spring AMQP MessageProperties オブジェクトを構築します。
Spring AMQP
MessageProperties と RabbitMQ BasicProperties の間で変換するための戦略インターフェース。 このインターフェースの実装は、再試行が使い果たされた後に失敗したメッセージを処理できます。
シャットダウン時に拒否されたメッセージを示す例外クラス。
Message をメッセージング抽象化から Message へ、またはその逆に変換します。これには、ペイロードの基礎となる MessageConverter と AmqpHeaderMapper を使用して、AMQP ヘッダーを標準メッセージヘッダーとの間でマッピングします。 構成可能な
HandlerAdapter を呼び出す MessageListener アダプター。 このエンドポイントの受信メッセージを処理するために呼び出すメソッドを提供する
RabbitListenerEndpoint。 リスナーアダプターのプロバイダー。
Micrometer への厳密な参照を避けるための抽象化。
不足しているキューが検出された場合に発行されるイベント。
MultiRabbit が有効な場合、
MultiRabbitListenerAnnotationBeanPostProcessor Bean を登録する ImportBeanDefinitionRegistrar クラス。 リスナーへの処理時に使用される適切な RabbitAdmin Bean を示す
RabbitListenerAnnotationBeanPostProcessor の拡張であり、返された宣言可能要素 (交換、キュー、バインディング) にも関連付けます。 名前空間パーサーの共有ユーティリティメソッド。
名前を生成するための戦略。
メッセージ処理のステートフルな再試行の最適化。
キューリーダーの接続ファクトリを取得するために使用されます。
このオブジェクトのインスタンスは、保留中の発行者の確認を追跡します。
Apache Pool2
GenericObjectPool (トランザクションチャネル用に 1 つ、非トランザクションチャネル用に 1 つ) を使用してチャネルをキャッシュする非常にシンプルな接続ファクトリ。 新しいプロデューサーが作成されたときに、
ProducerBuilder のカスタマイズを有効にするために呼び出されます。 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
JacksonProjectingMessageConverter を推奨する 4.0 以降。 このインターフェースのインスタンスは、コールバックにコンテキストを追加することにより、複数のチャネルでパブリッシャーが確認するために登録されている単一のリスナーをサポートします。
このインターフェースを実装するリスナーは、各チャネルで addListener を呼び出すことによって、複数のチャネルから受信したパブリッシャー確認に参加できます。
PublisherCallbackChannel のファクトリ。 単一のリスナーが複数のチャネルからの確認を処理できるようにするチャネルラッパー。
キューを説明するための情報を収集する単純なコンテナー。
QueueBinding の bindings 属性内で使用されるキュー定義。 キュー、キューがバインドされる交換、オプションのバインディングキーを定義します。
@RabbitListener で使用されます。 流れるような API を使用して Spring AMQP キューを構築します。
キューリーダーを見つけます。
オーバーフロー引数値。
パッシブ宣言から生じるキューに関する情報。
この例外は、リッスンできるキューがないため、コンシューマーを開始できなかったことを示します。
AMQP >= 0.9.1 のポータブル AMQP 管理操作の RabbitMQ 実装。
管理イベントの基本クラス。
RabbitMQ AMQP 1.0 クライアント用の
AmqpAdmin 実装。RabbitMQ AMQP 1.0 コンシューマーのリスナーコンテナー。
RabbitAmqpListenerContainer のファクトリ。RabbitMQ からネイティブ AMQP 1.0 メッセージを受信するメッセージリスナー。
RabbitMQ AMQP 1.0 プロトコルサポート用の
AmqpTemplate。RabbitMQ AMQP 1.0 プロトコル API 用のユーティリティ。
これでアノテーションが付けられたテストクラスは、localhost にブローカーがない場合は実行されません。
JUnit5
ExecutionCondition.Spring の @
RabbitListener アノテーションを処理できる RabbitListenerAnnotationBeanPostProcessor Bean を登録する ImportBeanDefinitionRegistrar クラス。 ファクトリ Bean は、RabbitMQ ConnectionFactory を作成し、ほとんどの setter メソッドを委譲し、オプションで証明書検証の有無にかかわらず SSL を有効にします。
テンプレートのジェネリクスパラメーターの戻り型を持つ
RabbitFuture。Rabbit 例外を
AmqpException クラス階層に変換します。AsyncRabbitTemplate によって返される CompletableFutureSE の基底クラス。RabbitMQ アクセスが必要なアプリケーションクラスの便利なスーパークラス。
RabbitListener でアノテーションが付けられたクラス内の Rabbit メッセージリスナーのターゲットであるメソッドをマークするアノテーション。 指定された
RabbitListener.queues() (または RabbitListener.bindings() ) の Rabbit メッセージリスナーのターゲットになるメソッドをマークするアノテーション。RabbitListener でアノテーションが付けられたメソッドを登録する Bean ポストプロセッサーは、アノテーションのパラメーターに従って RabbitListenerContainerFactory によってカバーに作成された AMQP メッセージリスナーコンテナーによって呼び出されます。MultiRabbitBootstrapConfiguration および RabbitBootstrapConfiguration をできるだけ遅くインポートするための最低次数の DeferredImportSelector 実装。Spring によって実装されるオプションのインターフェース Bean が Rabbit リスナーエンドポイントの構成方法をカスタマイズすることを望んでいます。
サブパッケージ間で内部共有するための構成定数。
MessageListenerContainer のファクトリ。Rabbit リスナーエンドポイントのモデル。
RabbitListenerEndpoint を RabbitListenerEndpointRegistry に登録するためのヘルパー Bean。 登録されたエンドポイントに必要な
MessageListenerContainer インスタンスを作成します。{code @RabbitListener} メソッドが例外をスローしたときに呼び出されるエラーハンドラー。
Spring Rabbit リスナーの観測。
Rabbit リスナーキー値のデフォルト
RabbitListenerObservationConvention。 高カーディナリティタグ。
カーディナリティの低いタグ。
Rabbit リスナーキー値の
ObservationConvention。 いくつかの
RabbitListener アノテーションを集約するコンテナーアノテーション。 これで
@Configuration クラスにアノテーションを付けて、プロキシ @RabbitListener Bean が引数と結果 (存在する場合) をキャプチャーできるようにします。 デフォルトの BPP を
RabbitListenerTestHarness でオーバーライドします。BeanPostProcessor 拡張
RabbitListenerAnnotationBeanPostProcessor。RabbitListenerTestBootstrap を登録するための RabbitListenerConfigurationSelector 拡張ですが、すでに上位にあるため、RabbitListenerTestHarness Bean は RabbitListenerAnnotationBeanPostProcessor よりも早く登録されます。 戻り値の型が
Message の RabbitFuture。MessageSendingOperations および MessageRequestReplyOperations を AMQP 関連の操作に特化したもので、交換だけでなく、使用するルーティングキーも指定できます。Message s の ReceiverContext。Message s の SenderContext。Rabbit の名前空間ハンドラー。
Amqp 機能の Rabbit 固有のメソッド。
複数の RabbitTemplate 操作に同じチャネルを使用するためのコールバック。
RabbitMQ 接続とチャネルをラップする Rabbit リソースホルダー。
spring-rabbit 用の
RuntimeHintsRegistrar。Spring Rabbit ストリームリスナーの監視。
Rabbit リスナーキー値のデフォルト
RabbitStreamListenerObservationConvention。 カーディナリティの低いタグ。
ObservationConvention (Rabbit ストリームリスナーキー値)。 ストリーム
Message の場合は ReceiverContext。Rabbit リスナーキー値のデフォルト
RabbitListenerObservationConvention。Messages の SenderContext。RabbitMQ Stream プロデューサーを使用してメッセージを送信するためのメソッドを提供します。
RabbitStreamOperations のデフォルト実装。RabbitStreamTemplate の Spring RabbitMQ 観測。Rabbit テンプレートキー値のデフォルト
RabbitStreamTemplateObservationConvention。 カーディナリティの低いタグ。
Rabbit ストリームテンプレートキー値の場合は
ObservationConvention。 同期 RabbitMQ アクセス (メッセージの送受信) を簡素化するヘルパークラス。
サイト運営者の確認のためのコールバック。
再試行ポリシーを使い果たしたリクエストを回復するためのコールバック。
返されたメッセージのコールバック。
RabbitTemplate.TemplateConsumer.toString() を DefaultConsumer に追加します。RabbitTemplate の Spring RabbitMQ 観測。Rabbit テンプレートキー値のデフォルト
RabbitTemplateObservationConvention。 カーディナリティの低いタグ。
Rabbit テンプレートキー値の
ObservationConvention。 単一の Rabbit
ConnectionFactory の PlatformTransactionManager 実装。AmqpTemplate の receive-and-reply メソッドで、受信 オブジェクトのプロセッサーおよび送信 オブジェクトのプロデューサーとして使用します。ReceiveAndReplyCallback の Message 交換契約。 リスナーコンテナーが再キューイングせずにメッセージを拒否する原因となる MessageRecover。
メッセージから変換するデリゲートを呼び出した後、
RemoteInvocationResult をアンラップする委譲アダプター。 リモート呼び出し結果をカプセル化し、結果値または例外を保持します。
リモート呼び出しを処理するための一般的なユーティリティ。
メッセージの応答の送信に失敗したときにスローされる例外。
応答を返すメッセージリスナー -
MessageListenerAdapter でラムダを使用することを目的としています。 返信用のポストプロセッサー。
メッセージヘッダー x-exception に格納された例外スタックトレースを使用して、復元されたメッセージを指定された交換に再発行する
MessageRecoverer 実装。RepublishMessageRecoverer サポートパブリッシャーが確認して返します。RestTemplate を使用した NodeLocator。 エラー時の動作を定義するための流れるようなインターフェースを提供することで、
StatefulRetryOperationsInterceptor または StatelessRetryOperationsInterceptor の構築をより簡単かつシンプルにする簡素化されたファサード。 ステートフルインターセプターのビルダー。
ステートレスインターセプターのビルダー。
返されたメッセージとそのメタデータ。
実装は、提供されたキーに基づいて接続ファクトリを選択します。
直列化を支援する静的ユーティリティ。
onShutDown メソッドのラムダを有効にする機能サブインターフェース。
AmqpHeaderMapper の単純な実装。1 つの exchange/routingKey のみをサポートする単純なバッチ処理戦略。バッチサイズ、バッチメッセージのサイズ制限、およびタイムアウトが含まれます。
単に接続。
文字列、シリアライズ可能なインスタンス、バイト配列を操作できる
MessageConverter の実装。(必須) プロパティの値を返す
ConnectionNameStrategy。 通常の
SimpleMessageListenerContainer を構築するための RabbitListenerContainerFactory 実装。RabbitListenerEndpoint は、このエンドポイントの受信メッセージを処理するために呼び出す MessageListener を提供するだけです。 リソース管理コードで使用されるスレッドごとにリソースを管理する主要ヘルパー。
この
ConnectionFactory のインスタンスのキーによって、スレッドにバインドされたリソースから現在の ConnectionFactory の lookupKey を取得する AbstractRoutingConnectionFactory 実装。 単一の共有
Connection インスタンスを保持するための AmqpConnectionFactory 実装。 変換ヒントをサポートする拡張
MessageConverter SPI。 インフラストラクチャ Bean を Spring Test コンテキストに追加します。Spring Boot には独自の自動構成メカニズムがあるため、Spring Boot では使用しないでください。
コンテナー型。
RetryPolicy を使用してメッセージ処理の状態を保持する MethodInterceptor 実装。 メッセージリスナーコンテナーで使用するステートフル再試行インターセプターを作成するための便利なファクトリ Bean により、リスナーが失敗したときのコンテナーの動作を広範囲に制御できます。
RetryOperations を使用してメソッド呼び出しを再試行する MethodInterceptor 実装。 メッセージリスナーコンテナーで使用するステートレス再試行インターセプターを作成するための便利なファクトリ Bean により、リスナーが失敗したときのコンテナーの動作を大幅に制御できます。
ストリームをプロビジョニングするために使用されます。
RabbitMQ Streams のリスナーコンテナー。
Message と Message の間で変換します。 ネイティブストリームメッセージを受信するメッセージリスナー。
ネイティブストリームメッセージを受信するリスナーアダプター。
ストリームメッセージの
MessageProperties 拡張。 このインターフェースの実装は、再試行が使い果たされた後に失敗したメッセージを処理できます。
StreamListenerContainer のファクトリ。
ネイティブストリームメッセージを消費するときに
StreamListenerContainer で使用するステートレス再試行インターセプターを作成するための便利なファクトリ Bean により、リスナーが失敗したときのコンテナーの動作を大幅に制御できます。 送信に失敗した場合にフューチャーを例外的に完了するために使用されます。
スーパーストリームトポロジ
Declarable を作成します。 流れるような API を使用して Spring AMQP スーパーストリームを構築します。
@RabbitListener を直接呼び出す RabbitTemplate。Spring Integration TestUtils を参照してください。
スレッドごとにチャネルをキャッシュする非常に単純な接続ファクトリ。
RabbitFuture のタイムアウトに使用される RunnableSE。 トピック交換を説明するための情報を収集する単純なコンテナー。
AmqpException 階層内で特定の原因が不明な場合の「キャッチオール」例外型。
ZipInputStreamSE を使用してメッセージ本文を解凍するポストプロセッサー。UUID.randomUUID() を使用して名前を生成します。 不変の値を表す
Expression インターフェースの非常に単純なハードコードされた実装。Spring WebFlux
WebClient を使用した NodeLocator。ZipOutputStreamSE を使用してメッセージ本文を圧縮するポストプロセッサー。
AbstractJacksonMessageConverterが優先されます。