パッケージ org.springframework.amqp.rabbit.core

インターフェース RabbitMessageOperations

すべてのスーパーインターフェース:
MessageReceivingOperations<StringSE>、MessageRequestReplyOperations<StringSE>、MessageSendingOperations<StringSE>
すべての既知の実装クラス:
RabbitMessagingTemplate
public interface RabbitMessageOperations extends MessageSendingOperations<StringSE>, MessageReceivingOperations<StringSE>, MessageRequestReplyOperations<StringSE>
MessageSendingOperations および MessageRequestReplyOperations を AMQP 関連の操作に特化したもので、交換だけでなく、使用するルーティングキーも指定できます。
導入:
1.4
作成者:
Stephane Nicoll
関連事項:

  • メソッドの詳細

    • send

      void send(StringSE exchange, StringSE routingKey, Message<?> message) throws MessagingException
      特定のルーティングキーを使用して、特定の交換にメッセージを送信します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      message - 送信するメッセージ
      例外:
      MessagingException - メッセージングの例外。

    • convertAndSend

      void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload) throws MessagingException
      おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、メッセージとしてラップして、特定のルーティングキーを使用して特定の交換に送信します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      payload - ペイロードとして使用するオブジェクト
      例外:
      MessagingException - メッセージングの例外。

    • convertAndSend

      void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MapSE<StringSE,ObjectSE> headers) throws MessagingException
      おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してメッセージとしてラップし、特定のルーティングキーを使用して特定の交換に送信します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      payload - ペイロードとして使用するオブジェクト
      headers - 送信するメッセージのヘッダー
      例外:
      MessagingException - メッセージングの例外。

    • convertAndSend

      void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MessagePostProcessor postProcessor) throws MessagingException
      おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、それをメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      payload - ペイロードとして使用するオブジェクト
      postProcessor - メッセージに適用するポストプロセッサー
      例外:
      MessagingException - メッセージングの例外。

    • convertAndSend

      void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MapSE<StringSE,ObjectSE> headers, MessagePostProcessor postProcessor) throws MessagingException
      おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      payload - ペイロードとして使用するオブジェクト
      headers - 送信するメッセージのヘッダー
      postProcessor - メッセージに適用するポストプロセッサー
      例外:
      MessagingException - メッセージングの例外。

    • sendAndReceive

      Message<?> sendAndReceive(StringSE exchange, StringSE routingKey, Message<?> requestMessage) throws MessagingException
      特定のルーティングキーを使用して特定の交換機にリクエストメッセージを送信し、応答を待ちます。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      requestMessage - 送信するメッセージ
      戻り値:
      応答。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 
      例外:
      MessagingException - メッセージングの例外。

    • convertSendAndReceive

      <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass) throws MessagingException
      おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、特定のルーティングキーを使用して特定の交換に Message として送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。
      型パラメーター:
      T - 戻りの型
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      request - 送信するリクエストメッセージのペイロード
      targetClass - 応答のペイロードを変換するターゲット型
      戻り値:
      応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 
      例外:
      MessagingException - メッセージングの例外。

    • convertSendAndReceive

      <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass) throws MessagingException
      おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用して Message として送信し、特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。
      型パラメーター:
      T - 戻りの型
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      request - 送信するリクエストメッセージのペイロード
      headers - 送信するリクエストメッセージのヘッダー
      targetClass - 応答のペイロードを変換するターゲット型
      戻り値:
      応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 
      例外:
      MessagingException - メッセージングの例外。

    • convertSendAndReceive

      <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass, MessagePostProcessor requestPostProcessor) throws MessagingException
      おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたポストプロセッサーを適用し、結果の Message を特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。
      型パラメーター:
      T - 戻りの型
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      request - 送信するリクエストメッセージのペイロード
      targetClass - 応答のペイロードを変換するターゲット型
      requestPostProcessor - リクエストメッセージに適用するポストプロセス
      戻り値:
      応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 
      例外:
      MessagingException - メッセージングの例外。

    • convertSendAndReceive

      <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass, MessagePostProcessor requestPostProcessor) throws MessagingException
      おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果の Message を特定のルーティングキーを使用して特定の交換に送信し、応答を受信して変換します。指定されたターゲットクラスの本体。
      型パラメーター:
      T - 戻りの型
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      request - 送信するリクエストメッセージのペイロード
      headers - 送信するメッセージのヘッダー
      targetClass - 応答のペイロードを変換するターゲット型
      requestPostProcessor - リクエストメッセージに適用するポストプロセス
      戻り値:
      応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 
      例外:
      MessagingException - メッセージングの例外。