クラス AmqpClient.Builder

方法の詳細

• senderOptions

  public AmqpClient.Builder senderOptions(org.apache.qpid.protonj2.client.SenderOptions senderOptions)

  内部 AMQP 1.0 Sender に対して SenderOptions を設定します。既存のインスタンスを上書きします。

  パラメーター:

  senderOptions - 使用します。

  戻り値:

  このビルダー。

  関連事項:

  • senderOptions(Consumer)

• senderOptions

  public AmqpClient.Builder senderOptions(ConsumerSE<org.apache.qpid.protonj2.client.SenderOptions> senderOptionsCustomizer)

  このビルダーで SenderOptions インスタンスをカスタマイズします。senderOptions(SenderOptions) を呼び出すと、既存のインスタンスが上書きされます。

  パラメーター:

  senderOptionsCustomizer - コンシューマーは既存の SenderOptions を受け入れます。

  戻り値:

  このビルダー。

  関連事項:

  • senderOptions(SenderOptions)

• completionTimeout

  public AmqpClient.Builder completionTimeout(DurationSE completionTimeout)

  リターン時の CompletableFuture.orTimeout(long, TimeUnit)SE の継続時間を設定します。CompletableFuture.get(long, TimeUnit)SE からリクエストされる onTimeout() のような CompletableFutureSE API はありませんが、CompletableFutureSE のフルフィルメントとは独立して、AMQP リソースを最終的に閉じる必要がある操作で使用されます。デフォルトは 1 分です。

  パラメーター:

  completionTimeout - 将来の完了までの期間。

  戻り値:

  このビルダー。

• defaultToAddress

  public AmqpClient.Builder defaultToAddress(StringSE defaultToAddress)

  AmqpClient.sendToDefault(org.springframework.amqp.core.Message) および AmqpClient.send(Message) 操作のデフォルトのターゲット AMQP 1.0 アドレスを設定します。

  パラメーター:

  defaultToAddress - 便利なデフォルトとして使用するターゲットアドレス。

  戻り値:

  このビルダー。

• messageConverter

  public AmqpClient.Builder messageConverter(MessageConverter messageConverter)

  メッセージ本文との変換に使用する MessageConverter を設定します。ObjectSE 以外のジェネリクス型を持つ AmqpClient.ReceiveSpec.receiveAndConvert(T...) の場合、このコンバーターは SmartMessageConverter である必要があります。

  パラメーター:

  messageConverter - コンバーター。

  戻り値:

  このビルダー。

• taskExecutor

  public AmqpClient.Builder taskExecutor(TaskExecutor taskExecutor)

  非同期操作用に TaskExecutor を設定します。デフォルトでは、1 つのコアプールスレッドを持つ ThreadPoolExecutorSE が使用されます。

  パラメーター:

  taskExecutor - タスクエグゼキュータ。

  戻り値:

  このビルダー。

• build

  public AmqpClient build()

  提供されたオプションに基づいて AmqpClient インスタンスを構築します。

  戻り値:

  クライアントインスタンス。