インターフェース AsyncAmqpTemplate

メソッドの詳細

• sendAndReceive

  CompletableFutureSE<Message> sendAndReceive(Message message)

  デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合は、一意である必要があります。

  パラメーター:

  message - メッセージ。

  戻り値:

  CompletableFutureSE

• sendAndReceive

  CompletableFutureSE<Message> sendAndReceive(StringSE routingKey, Message message)

  指定されたルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合は、一意である必要があります。

  パラメーター:

  routingKey - ルーティングキー。

  message - メッセージ。

  戻り値:

  CompletableFutureSE

• sendAndReceive

  CompletableFutureSE<Message> sendAndReceive(StringSE exchange, StringSE routingKey, Message message)

  指定された交換およびルーティングキーにメッセージを送信します。メッセージに correlationId プロパティが含まれている場合は、一意である必要があります。

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

  message - メッセージ。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  <C> CompletableFutureSE<C> convertSendAndReceive(ObjectSE object)

  オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  object - 変換するオブジェクト。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  <C> CompletableFutureSE<C> convertSendAndReceive(StringSE routingKey, ObjectSE object)

  オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  <C> CompletableFutureSE<C> convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE object)

  オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  <C> CompletableFutureSE<C> convertSendAndReceive(ObjectSE object, MessagePostProcessor messagePostProcessor)

  オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  <C> CompletableFutureSE<C> convertSendAndReceive(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor)

  オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  <C> CompletableFutureSE<C> convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor)

  MessagePostProcessor を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  <C> CompletableFutureSE<C> convertSendAndReceiveAsType(ObjectSE object, ParameterizedTypeReference<C> responseType)

  オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  object - 変換するオブジェクト。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  <C> CompletableFutureSE<C> convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)

  オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  <C> CompletableFutureSE<C> convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)

  オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  <C> CompletableFutureSE<C> convertSendAndReceiveAsType(ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)

  オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  <C> CompletableFutureSE<C> convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)

  オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  <C> CompletableFutureSE<C> convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)

  MessagePostProcessor を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE