インターフェース NodeLocator<T>

メソッドの詳細

• locate

  @Nullable default ConnectionFactory locate(StringSE[] adminUris, MapSE<StringSE,StringSE> nodeToAddress, StringSE vhost, StringSE username, StringSE password, StringSE queue, FactoryFinder factoryFunction)

  キューのリーダーノードの接続ファクトリを返します。

  パラメーター:

  adminUris - 管理 URI の配列。

  nodeToAddress - ノード名からノードアドレスへのマップ (AMQP)。

  vhost - 仮想ホスト。

  username - ユーザー名。

  password - パスワード。

  queue - キュー名。

  factoryFunction - ファクトリを検索または作成するための内部関数。

  戻り値:

  リーダーノードが見つかった場合は接続ファクトリ。それ以外の場合は null。

• createClient

  T createClient(StringSE userName, StringSE password)

  後で使用するためにクライアントを作成します。

  パラメーター:

  userName - ユーザー名。

  password - パスワード。

  戻り値:

  クライアント。

• close

  default void close(T client)

  クライアントを閉じます。

  パラメーター:

  client - クライアント。

• restCall

  @Nullable MapSE<StringSE,ObjectSE> restCall(T client, StringSE baseUri, StringSE vhost, StringSE queue) throws URISyntaxExceptionSE

  RabbitMQ 管理 REST API を使用して、キュープロパティのマップを取得します。

  パラメーター:

  client - クライアント。

  baseUri - ベース uri。

  vhost - 仮想ホスト。

  queue - キュー名。

  戻り値:

  キュープロパティのマップ。

  例外:

  URISyntaxExceptionSE - 構文が悪い場合。