インターフェース AmqpClient.ReceiveSpec

方法の詳細

• timeout

  AmqpClient.ReceiveSpec timeout(DurationSE timeout)

  配信のタイムアウトを設定します。最大値は AmqpClient.Builder.completionTimeout(Duration) によって制限され、デフォルトでは 1 分です。

  パラメーター:

  timeout - 配達を待つ。

  戻り値:

  メッセージ付きの CompletableFutureSE。

• receive

  default CompletableFutureSE<Message> receive()

  指定された from アドレスから Spring AMQP メッセージを受信します。

  戻り値:

  メッセージ付きの CompletableFutureSE。

• receiveProtonMessage

  CompletableFutureSE<org.apache.qpid.protonj2.client.Message<?>> receiveProtonMessage()

  提供された from アドレスからネイティブ ProtonJ メッセージを受信します。

  戻り値:

  メッセージ付きの CompletableFutureSE。

• receiveAndConvert

  <T> CompletableFutureSE<T> receiveAndConvert(T... reified)

  指定された from アドレスからメッセージを受信し、その本文を指定された汎用型に変換します。

  型パラメーター:

  T - メッセージ本文を変換する型。

  パラメーター:

  reified - 変換用のジェネリクス型を抽出するために使用される引数。設定しないでください。

  戻り値:

  メッセージ本体から変換された予想される型のペイロードを持つ CompletableFutureSE。