メソッドの詳細

• sendAndReceive

  ListenableFuture<Message> sendAndReceive(Message message)

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

  パラメーター:

  message - メッセージ。

  戻り値:

  ListenableFuture

• sendAndReceive

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

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

  パラメーター:

  routingKey - ルーティングキー。

  message - メッセージ。

  戻り値:

  ListenableFuture

• sendAndReceive

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

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

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

  message - メッセージ。

  戻り値:

  ListenableFuture

• convertSendAndReceive

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

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

  戻り値:

  ListenableFuture

• convertSendAndReceive

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

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

  戻り値:

  ListenableFuture

• convertSendAndReceive

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

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

  戻り値:

  ListenableFuture

• convertSendAndReceive

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

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

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

  戻り値:

  ListenableFuture

• convertSendAndReceive

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

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

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

  戻り値:

  ListenableFuture

• convertSendAndReceive

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換

  routingKey - ルーティングキー。

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

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

  戻り値:

  ListenableFuture

• convertSendAndReceiveAsType

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

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

  responseType - レスポンス型。

  戻り値:

  ListenableFuture

• convertSendAndReceiveAsType

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

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

  responseType - レスポンス型。

  戻り値:

  ListenableFuture

• convertSendAndReceiveAsType

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

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

  responseType - レスポンス型。

  戻り値:

  ListenableFuture

• convertSendAndReceiveAsType

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

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

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

  responseType - レスポンス型。

  戻り値:

  ListenableFuture

• convertSendAndReceiveAsType

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

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

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

  responseType - レスポンス型。

  戻り値:

  ListenableFuture

• convertSendAndReceiveAsType

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

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

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換

  routingKey - ルーティングキー。

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

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

  responseType - レスポンス型。

  戻り値:

  ListenableFuture