インターフェース RabbitMessageOperations

方法の詳細

• send

  void send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message<?> message) throws MessagingException

  特定のルーティングキーを使用して、特定の交換にメッセージを送信します。

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  例外:

  MessagingException - メッセージングの例外。

• convertAndSend

  default void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE payload) throws MessagingException

  おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、メッセージとしてラップして、特定のルーティングキーを使用して特定の交換に送信します。

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  payload - ペイロードとして使用するオブジェクト

  例外:

  MessagingException - メッセージングの例外。

• convertAndSend

  default void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE payload, @Nullable MapSE<StringSE,ObjectSE> headers) throws MessagingException

  おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してメッセージとしてラップし、特定のルーティングキーを使用して特定の交換に送信します。

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  payload - ペイロードとして使用するオブジェクト

  headers - 送信するメッセージのヘッダー

  例外:

  MessagingException - メッセージングの例外。

• convertAndSend

  default void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE payload, @Nullable MessagePostProcessor postProcessor) throws MessagingException

  おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、それをメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  payload - ペイロードとして使用するオブジェクト

  postProcessor - メッセージに適用するポストプロセッサー

  例外:

  MessagingException - メッセージングの例外。

• convertAndSend

  void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE payload, @Nullable MapSE<StringSE,ObjectSE> headers, @Nullable MessagePostProcessor postProcessor) throws MessagingException

  おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  payload - ペイロードとして使用するオブジェクト

  headers - 送信するメッセージのヘッダー

  postProcessor - メッセージに適用するポストプロセッサー

  例外:

  MessagingException - メッセージングの例外。

• sendAndReceive

  @Nullable Message<?> sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message<?> requestMessage) throws MessagingException

  特定のルーティングキーを使用して特定の交換機にリクエストメッセージを送信し、応答を待ちます。

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  requestMessage - 送信するメッセージ

  戻り値:

  応答。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。

• convertSendAndReceive

  default <T> @Nullable T convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE request, ClassSE<T> targetClass) throws MessagingException

  おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、特定のルーティングキーを使用して特定の交換に Message として送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。

  型パラメーター:

  T - 戻りの型

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  request - 送信するリクエストメッセージのペイロード

  targetClass - 応答のペイロードを変換するターゲット型

  戻り値:

  応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。

• convertSendAndReceive

  default <T> @Nullable T convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE request, @Nullable MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass) throws MessagingException

  おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用して Message として送信し、特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。

  型パラメーター:

  T - 戻りの型

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  request - 送信するリクエストメッセージのペイロード

  headers - 送信するリクエストメッセージのヘッダー

  targetClass - 応答のペイロードを変換するターゲット型

  戻り値:

  応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。

• convertSendAndReceive

  default <T> @Nullable T convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE request, ClassSE<T> targetClass, @Nullable MessagePostProcessor requestPostProcessor) throws MessagingException

  おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたポストプロセッサーを適用し、結果の Message を特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。

  型パラメーター:

  T - 戻りの型

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  request - 送信するリクエストメッセージのペイロード

  targetClass - 応答のペイロードを変換するターゲット型

  requestPostProcessor - リクエストメッセージに適用するポストプロセス

  戻り値:

  応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。

• convertSendAndReceive

  <T> @Nullable T convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE request, @Nullable MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass, @Nullable MessagePostProcessor requestPostProcessor) throws MessagingException

  指定されたリクエストオブジェクトを、おそらく MessageConverter を使用して直列化された形式に変換し、指定されたヘッダーを持つメッセージとしてラップし、指定されたポストプロセッサーを適用して、結果の Message を特定のルーティングキーを持つ特定の交換に送信し、応答を受信して、その本文を指定されたターゲットクラスに変換します。

  型パラメーター:

  T - 戻りの型

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  request - 送信するリクエストメッセージのペイロード

  headers - 送信するメッセージのヘッダー

  targetClass - 応答のペイロードを変換するターゲット型

  requestPostProcessor - リクエストメッセージに適用するポストプロセス

  戻り値:

  応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。