パッケージ org.springframework.amqp.rabbit.connection

クラス LocalizedQueueConnectionFactory

  • 実装されているすべてのインターフェース:
    ConnectionFactory、RoutingConnectionFactory、DisposableBean
    public class LocalizedQueueConnectionFactory
extends ObjectSE
implements ConnectionFactory, RoutingConnectionFactory, DisposableBean
    キューが配置されているノードを決定し、そのノードに直接接続するファクトリを返す RoutingConnectionFactory。RabbitMQ 管理プラグインが REST 経由で呼び出されてノードが決定され、そのノードに対応するアドレスが接続ファクトリに挿入されます。各接続ファクトリの 1 つのインスタンスがキャッシュに保持されます。場所を判別できない場合は、デフォルトの接続ファクトリが返されます。通常、この接続ファクトリは、フェイルオーバーモードですべてのサーバーに接続するように構成されます。

    getTargetConnectionFactory(Object) は、接続を確立するときに、'[queueName]' 形式の検索キーを使用して SimpleMessageListenerContainer によって呼び出されます。

    すべての ConnectionFactory メソッドはデフォルトに委譲されます

    導入:
    1.2
    作成者:
    Gary Russell

    • コンストラクターの詳細

      • LocalizedQueueConnectionFactory

        public LocalizedQueueConnectionFactory​(ConnectionFactory defaultConnectionFactory,
                                       MapSE<StringSE,​StringSE> nodeToAddress,
                                       StringSE[] adminUris,
                                       StringSE vhost,
                                       StringSE username,
                                       StringSE password,
                                       boolean useSSL,
                                       Resource sslPropertiesLocation)
        パラメーター:
        defaultConnectionFactory - キューが見つからない場合に使用するフォールバック接続ファクトリ。
        nodeToAddress - アドレスへのノードのマップ: (うさぎ @ サーバー 1: サーバー 1:5672)
        adminUris - rabbitmq 管理アドレス (https://host:port,...) は、アドレスと同じ長さでなければなりません。
        vhost - 仮想ホスト。
        username - ユーザー名。
        password - パスワード。
        useSSL - SSL を使用する。
        sslPropertiesLocation - SSL プロパティの場所。

      • LocalizedQueueConnectionFactory

        public LocalizedQueueConnectionFactory​(ConnectionFactory defaultConnectionFactory,
                                       MapSE<StringSE,​StringSE> nodeToAddress,
                                       StringSE[] adminUris,
                                       StringSE vhost,
                                       StringSE username,
                                       StringSE password,
                                       boolean useSSL,
                                       StringSE keyStore,
                                       StringSE trustStore,
                                       StringSE keyStorePassPhrase,
                                       StringSE trustStorePassPhrase)
        パラメーター:
        defaultConnectionFactory - キューが見つからない場合に使用するフォールバック接続ファクトリ。
        nodeToAddress - アドレスへのノードのマップ: (うさぎ @ サーバー 1: サーバー 1:5672)
        adminUris - rabbitmq 管理アドレス (https://host:port,...) は、アドレスと同じ長さでなければなりません。
        vhost - 仮想ホスト。
        username - ユーザー名。
        password - パスワード。
        useSSL - SSL を使用する。
        keyStore - キーストアリソース (例: "file:/foo/keystore")。
        trustStore - トラストストアリソース (例: "file:/foo/truststore")。
        keyStorePassPhrase - キーストアのパスフレーズ。
        trustStorePassPhrase - トラストストアのパスフレーズ。

      • LocalizedQueueConnectionFactory

        public LocalizedQueueConnectionFactory​(ConnectionFactory defaultConnectionFactory,
                                       StringSE[] addresses,
                                       StringSE[] adminUris,
                                       StringSE[] nodes,
                                       StringSE vhost,
                                       StringSE username,
                                       StringSE password,
                                       boolean useSSL,
                                       @Nullable
                                       Resource sslPropertiesLocation)
        パラメーター:
        defaultConnectionFactory - キューが見つからない場合に使用するフォールバック接続ファクトリ。
        addresses - rabbitmq サーバーのアドレス (ホスト: ポートなど)。
        adminUris - rabbitmq 管理アドレス (https://host:port,...)
        nodes - アドレス (rabbit@server1,...) に対応する Rabbitmq ノードは、アドレスと同じ長さでなければなりません。
        vhost - 仮想ホスト。
        username - ユーザー名。
        password - パスワード。
        useSSL - SSL を使用する。
        sslPropertiesLocation - SSL プロパティの場所。

      • LocalizedQueueConnectionFactory

        public LocalizedQueueConnectionFactory​(ConnectionFactory defaultConnectionFactory,
                                       StringSE[] addresses,
                                       StringSE[] adminUris,
                                       StringSE[] nodes,
                                       StringSE vhost,
                                       StringSE username,
                                       StringSE password,
                                       boolean useSSL,
                                       StringSE keyStore,
                                       StringSE trustStore,
                                       StringSE keyStorePassPhrase,
                                       StringSE trustStorePassPhrase)
        パラメーター:
        defaultConnectionFactory - キューが見つからない場合に使用するフォールバック接続ファクトリ。
        addresses - rabbitmq サーバーのアドレス (ホスト: ポートなど)。
        adminUris - rabbitmq 管理アドレス (https://host:port,...)。
        nodes - アドレス (rabbit@server1,...) に対応する Rabbitmq ノードは、アドレスと同じ長さでなければなりません。
        vhost - 仮想ホスト。
        username - ユーザー名。
        password - パスワード。
        useSSL - SSL を使用する。
        keyStore - キーストアリソース (例: "file:/foo/keystore")。
        trustStore - トラストストアリソース (例: "file:/foo/truststore")。
        keyStorePassPhrase - キーストアのパスフレーズ。
        trustStorePassPhrase - トラストストアのパスフレーズ。