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