クラス LocalizedQueueConnectionFactory

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

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

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

導入:
1.2
作成者:
Gary Russell, Christian Tzolov, Ngoc Nhan

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

    • LocalizedQueueConnectionFactory

      public LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, MapSE<StringSE,StringSE> nodeToAddress, StringSE[] adminUris, StringSE vhost, StringSE username, StringSE password, boolean useSSL, Resource sslPropertiesLocation)
      パラメーター:
      defaultConnectionFactory - キューが見つからない場合に使用するフォールバック接続ファクトリ。
      nodeToAddress - ノードからアドレスへのマップ: rabbit@server1 : server1: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 - ノードからアドレスへのマップ: rabbit@server1 : server1: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 - トラストストアのパスフレーズ。

  • メソッドの詳細