パッケージ org.springframework.amqp.rabbit.connection
@NullMarked パッケージ org.springframework.amqp.rabbit.connection
接続に関連するクラスを提供します。
- クラス説明アドレスのシャッフルに使用されるモード。チャネルクローズ例外をログに記録するための
ConditionalExceptionLoggerのデフォルト実装。ルックアップキーに基づいてAbstractRoutingConnectionFactory.createConnection()呼び出しをさまざまなターゲット ConnectionFactories のいずれかにルーティングする抽象ConnectionFactory実装。プライマリトランザクションが完了した後に afterCompletion を実行するときにコミットまたはロールバックに失敗したことを示します。接続が現在開かれておらず、回復中の自動回復接続である場合にスローされる例外。(キャッシュモードがCachingConnectionFactory.CacheMode.CHANNEL(デフォルト) の場合、すべてのCachingConnectionFactory.createConnection()呼び出しから同じ接続を返し、Connection.close()への呼び出しを無視してChannelをキャッシュするConnectionFactory実装。キャッシュモード。パブリッシャーの型は、使用を確認します。新しいチャネルの作成と破棄のリスナー。チャネルプロキシによって実装されるChannelのサブインターフェース。孤立したコンシューマーを回避するために、回復されたチャネルを閉じるRecoveryListener。デリゲートを順番に呼び出す複合リスナー。接続がブロックされたときにCachingConnectionFactoryによって発行されるAmqpEvent。Connectionsを作成するためのインターフェースベースの ConnectionFactory。接続ファクトリを構成するためのユーティリティメソッド。命令の実行時にConnectionFactoryコンテキストのバインドとバインド解除を処理するヘルパークラス。Spring ベースの RabbitConnectionFactoryを管理するためのヘルパークラス。特に、特定の ConnectionFactory のトランザクション Rabbit リソースを取得するためのものです。リソース作成用のコールバックインターフェース。接続の作成と終了のリスナー。アプリケーション固有の接続名を作成する戦略。RabbitMQ サーバーがサポートしている場合、管理 UI に表示できます。接続プロキシによって実装されるConnectionのサブインターフェース。接続のブロックが解除されたときにCachingConnectionFactoryによって発行されるAmqpEvent。コンシューマーは、プライマリチャネルをこのクラスに登録します。パブリッシャーの確認を送信済みメッセージに関連付けるための基本クラス。発行元の確認を表します。提供された情報を使用して接続ファクトリを決定するためのコールバック。キューが配置されているノードを決定し、そのノードに直接接続するファクトリを返すRoutingConnectionFactory。NodeLocator<T>キューリーダーの接続ファクトリを取得するために使用されます。このオブジェクトのインスタンスは、保留中の発行者の確認を追跡します。Apache Pool2GenericObjectPool(トランザクションチャネル用に 1 つ、非トランザクションチャネル用に 1 つ) を使用してチャネルをキャッシュする非常にシンプルな接続ファクトリ。このインターフェースのインスタンスは、コールバックにコンテキストを追加することにより、複数のチャネルでパブリッシャーが確認するために登録されている単一のリスナーをサポートします。このインターフェースを実装するリスナーは、各チャネルで addListener を呼び出すことによって、複数のチャネルから受信したパブリッシャー確認に参加できます。PublisherCallbackChannelのファクトリ。単一のリスナーが複数のチャネルからの確認を処理できるようにするチャネルラッパー。ファクトリ Bean は、RabbitMQ ConnectionFactory を作成し、ほとんどの setter メソッドを委譲し、オプションで証明書検証の有無にかかわらず SSL を有効にします。RabbitMQ 接続とチャネルをラップする Rabbit リソースホルダー。RestTemplateを使用したNodeLocator。実装は、提供されたキーに基づいて接続ファクトリを選択します。onShutDown メソッドのラムダを有効にする機能サブインターフェース。単に接続。(必須) プロパティの値を返すConnectionNameStrategy。リソース管理コードで使用されるスレッドごとにリソースを管理する主要ヘルパー。このConnectionFactoryのインスタンスのキーによって、スレッドにバインドされたリソースから現在のConnectionFactoryのlookupKeyを取得するAbstractRoutingConnectionFactory実装。スレッドごとにチャネルをキャッシュする非常に単純な接続ファクトリ。