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

インターフェース AmqpTemplate

  • すべての既知のサブインターフェース:
    RabbitOperations
    すべての既知の実装クラス:
    BatchingRabbitTemplate、RabbitTemplate、TestRabbitTemplate
    public interface AmqpTemplate
    AMQP 操作の基本セットを指定します。同期送信および受信メソッドを提供します。convertAndSend(Object) および receiveAndConvert() メソッドを使用すると、POJO オブジェクトを送受信できます。実装は、AMQP byte[] ペイロード型との間の変換を実行するために、MessageConverter のインスタンスに委譲することが期待されています。
    作成者:
    Mark Pollack, Mark Fisher, Artem Bilan, Ernest Sadykov, Gary Russell

    • メソッドのサマリー

      すべてのメソッド   インスタンスメソッド   抽象メソッド  
      修飾子と型 メソッド 説明
      voidconvertAndSend​(java.lang.Object message)
      Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。
      voidconvertAndSend​(java.lang.Object message, MessagePostProcessor messagePostProcessor)
      Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。
      voidconvertAndSend​(java.lang.String routingKey, java.lang.Object message)
      Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。
      voidconvertAndSend​(java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor)
      Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。
      voidconvertAndSend​(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message)
      Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。
      voidconvertAndSend​(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor)
      Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。
      java.lang.ObjectconvertSendAndReceive​(java.lang.Object message)
      変換を伴う基本的な RPC パターン。
      java.lang.ObjectconvertSendAndReceive​(java.lang.Object message, MessagePostProcessor messagePostProcessor)
      変換を伴う基本的な RPC パターン。
      java.lang.ObjectconvertSendAndReceive​(java.lang.String routingKey, java.lang.Object message)
      変換を伴う基本的な RPC パターン。
      java.lang.ObjectconvertSendAndReceive​(java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor)
      変換を伴う基本的な RPC パターン。
      java.lang.ObjectconvertSendAndReceive​(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message)
      変換を伴う基本的な RPC パターン。
      java.lang.ObjectconvertSendAndReceive​(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor)
      変換を伴う基本的な RPC パターン。
      <T> TconvertSendAndReceiveAsType​(java.lang.Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
      変換を伴う基本的な RPC パターン。
      <T> TconvertSendAndReceiveAsType​(java.lang.Object message, ParameterizedTypeReference<T> responseType)
      変換を伴う基本的な RPC パターン。
      <T> TconvertSendAndReceiveAsType​(java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
      変換を伴う基本的な RPC パターン。
      <T> TconvertSendAndReceiveAsType​(java.lang.String routingKey, java.lang.Object message, ParameterizedTypeReference<T> responseType)
      変換を伴う基本的な RPC パターン。
      <T> TconvertSendAndReceiveAsType​(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
      変換を伴う基本的な RPC パターン。
      <T> TconvertSendAndReceiveAsType​(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message, ParameterizedTypeReference<T> responseType)
      変換を伴う基本的な RPC パターン。
      Messagereceive()
      デフォルトキューからのメッセージがある場合は、メッセージを受信します。
      Messagereceive​(long timeoutMillis)
      デフォルトのキューからメッセージを受信し、メッセージが利用可能になるまで必要に応じて指定された待機時間まで待機します。
      Messagereceive​(java.lang.String queueName)
      特定のキューからのメッセージがある場合、メッセージを受信します。
      Messagereceive​(java.lang.String queueName, long timeoutMillis)
      特定のキューからメッセージを受信し、メッセージが使用可能になるまで必要に応じて指定された待機時間まで待機します。
      java.lang.ObjectreceiveAndConvert()
      デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。
      java.lang.ObjectreceiveAndConvert​(long timeoutMillis)
      デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。
      <T> TreceiveAndConvert​(long timeoutMillis, ParameterizedTypeReference<T> type)
      デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。
      java.lang.ObjectreceiveAndConvert​(java.lang.String queueName)
      特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。
      java.lang.ObjectreceiveAndConvert​(java.lang.String queueName, long timeoutMillis)
      特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。
      <T> TreceiveAndConvert​(java.lang.String queueName, long timeoutMillis, ParameterizedTypeReference<T> type)
      特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。
      <T> TreceiveAndConvert​(java.lang.String queueName, ParameterizedTypeReference<T> type)
      特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。
      <T> TreceiveAndConvert​(ParameterizedTypeReference<T> type)
      デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。
      <R,​S>
      boolean      		receiveAndReply​(java.lang.String queueName, ReceiveAndReplyCallback<R,​S> callback)
      指定されたキューからメッセージがある場合はそれを受信し、指定された ReceiveAndReplyCallback を呼び出して、callback が応答メッセージを返した場合は、MessageProperties から replyTo Address に、またはデフォルトの交換とデフォルトの routingKey に応答メッセージを送信します。
      <R,​S>
      boolean      		receiveAndReply​(java.lang.String queueName, ReceiveAndReplyCallback<R,​S> callback, java.lang.String replyExchange, java.lang.String replyRoutingKey)
      提供されたキューからメッセージがある場合はメッセージを受信し、提供された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、提供された exchange および routingKey に応答メッセージを送信します。
      <R,​S>
      boolean      		receiveAndReply​(java.lang.String queueName, ReceiveAndReplyCallback<R,​S> callback, ReplyToAddressCallback<S> replyToAddressCallback)
      指定されたキューからメッセージがあれば受信し、指定された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、応答メッセージを ReplyToAddressCallback の結果から replyTo Address に送信します。
      <R,​S>
      boolean      		receiveAndReply​(ReceiveAndReplyCallback<R,​S> callback)
      デフォルトキューからメッセージがある場合はそれを受信し、提供された ReceiveAndReplyCallback を呼び出して、callback が応答メッセージを返した場合は、MessageProperties から replyTo Address に、またはデフォルト交換とデフォルト routingKey に応答メッセージを送信します。
      <R,​S>
      boolean      		receiveAndReply​(ReceiveAndReplyCallback<R,​S> callback, java.lang.String replyExchange, java.lang.String replyRoutingKey)
      デフォルトキューからメッセージがある場合はメッセージを受信し、提供された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、提供された exchange および routingKey に応答メッセージを送信します。
      <R,​S>
      boolean      		receiveAndReply​(ReceiveAndReplyCallback<R,​S> callback, ReplyToAddressCallback<S> replyToAddressCallback)
      デフォルトのキューからメッセージがあれば受信し、提供された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、応答メッセージを ReplyToAddressCallback の結果から replyTo Address に送信します。
      voidsend​(java.lang.String exchange, java.lang.String routingKey, Message message)
      特定のルーティングキーを使用して、特定の交換にメッセージを送信します。
      voidsend​(java.lang.String routingKey, Message message)
      特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。
      voidsend​(Message message)
      デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。
      MessagesendAndReceive​(java.lang.String exchange, java.lang.String routingKey, Message message)
      基本的な RPC パターン。
      MessagesendAndReceive​(java.lang.String routingKey, Message message)
      基本的な RPC パターン。
      MessagesendAndReceive​(Message message)
      基本的な RPC パターン。

    • メソッドの詳細

      • send

        void send​(Message message)
   throws AmqpException
        デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。
        パラメーター:
        message - 送信するメッセージ
        例外:
        AmqpException - 問題がある場合

      • send

        void send​(java.lang.String routingKey,
          Message message)
   throws AmqpException
        特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。
        パラメーター:
        routingKey - ルーティングキー
        message - 送信するメッセージ
        例外:
        AmqpException - 問題がある場合

      • send

        void send​(java.lang.String exchange,
          java.lang.String routingKey,
          Message message)
   throws AmqpException
        特定のルーティングキーを使用して、特定の交換にメッセージを送信します。
        パラメーター:
        exchange - 取引所の名前
        routingKey - ルーティングキー
        message - 送信するメッセージ
        例外:
        AmqpException - 問題がある場合

      • convertAndSend

        void convertAndSend​(java.lang.Object message)
             throws AmqpException
        Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。
        パラメーター:
        message - 送信するメッセージ
        例外:
        AmqpException - 問題がある場合

      • convertAndSend

        void convertAndSend​(java.lang.String routingKey,
                    java.lang.Object message)
             throws AmqpException
        Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。
        パラメーター:
        routingKey - ルーティングキー
        message - 送信するメッセージ
        例外:
        AmqpException - 問題がある場合

      • convertAndSend

        void convertAndSend​(java.lang.String exchange,
                    java.lang.String routingKey,
                    java.lang.Object message)
             throws AmqpException
        Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。
        パラメーター:
        exchange - 取引所の名前
        routingKey - ルーティングキー
        message - 送信するメッセージ
        例外:
        AmqpException - 問題がある場合

      • convertAndSend

        void convertAndSend​(java.lang.Object message,
                    MessagePostProcessor messagePostProcessor)
             throws AmqpException
        Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。
        パラメーター:
        message - 送信するメッセージ
        messagePostProcessor - 送信前にメッセージに適用するプロセッサー
        例外:
        AmqpException - 問題がある場合

      • convertAndSend

        void convertAndSend​(java.lang.String routingKey,
                    java.lang.Object message,
                    MessagePostProcessor messagePostProcessor)
             throws AmqpException
        Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。
        パラメーター:
        routingKey - ルーティングキー
        message - 送信するメッセージ
        messagePostProcessor - 送信前にメッセージに適用するプロセッサー
        例外:
        AmqpException - 問題がある場合

      • convertAndSend

        void convertAndSend​(java.lang.String exchange,
                    java.lang.String routingKey,
                    java.lang.Object message,
                    MessagePostProcessor messagePostProcessor)
             throws AmqpException
        Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。
        パラメーター:
        exchange - 取引所の名前
        routingKey - ルーティングキー
        message - 送信するメッセージ
        messagePostProcessor - 送信前にメッセージに適用するプロセッサー
        例外:
        AmqpException - 問題がある場合

      • receive

        @Nullable
Message receive()
         throws AmqpException
        デフォルトキューからのメッセージがある場合は、メッセージを受信します。おそらく null 値で、すぐに戻ります。
        戻り値:
        待っているメッセージがない場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合

      • receive

        @Nullable
Message receive​(java.lang.String queueName)
         throws AmqpException
        特定のキューからのメッセージがある場合、メッセージを受信します。おそらく null 値で、すぐに戻ります。
        パラメーター:
        queueName - ポーリングするキューの名前
        戻り値:
        待っているメッセージがない場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合

      • receive

        @Nullable
Message receive​(long timeoutMillis)
         throws AmqpException
        デフォルトのキューからメッセージを受信し、メッセージが利用可能になるまで必要に応じて指定された待機時間まで待機します。
        パラメーター:
        timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。
        戻り値:
        期限が切れた場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合
        導入:
        1.6

      • receive

        @Nullable
Message receive​(java.lang.String queueName,
                long timeoutMillis)
         throws AmqpException
        特定のキューからメッセージを受信し、メッセージが使用可能になるまで必要に応じて指定された待機時間まで待機します。
        パラメーター:
        queueName - 受信するキュー
        timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。
        戻り値:
        期限が切れた場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合
        導入:
        1.6

      • receiveAndConvert

        @Nullable
java.lang.Object receiveAndConvert()
                            throws AmqpException
        デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。
        戻り値:
        待っているメッセージがない場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合

      • receiveAndConvert

        @Nullable
java.lang.Object receiveAndConvert​(java.lang.String queueName)
                            throws AmqpException
        特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。
        パラメーター:
        queueName - ポーリングするキューの名前
        戻り値:
        待っているメッセージがない場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合

      • receiveAndConvert

        @Nullable
java.lang.Object receiveAndConvert​(long timeoutMillis)
                            throws AmqpException
        デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。
        パラメーター:
        timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。
        戻り値:
        期限が切れた場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合
        導入:
        1.6

      • receiveAndConvert

        @Nullable
java.lang.Object receiveAndConvert​(java.lang.String queueName,
                                   long timeoutMillis)
                            throws AmqpException
        特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。
        パラメーター:
        queueName - ポーリングするキューの名前
        timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。
        戻り値:
        期限が切れた場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合
        導入:
        1.6

      • receiveAndConvert

        @Nullable
<T> T receiveAndConvert​(ParameterizedTypeReference<T> type)
                 throws AmqpException
        デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        type - 変換する型。
        戻り値:
        メッセージ、または待機していない場合は null。
        例外:
        AmqpException - 問題がある場合。
        導入:
        2.0

      • receiveAndConvert

        @Nullable
<T> T receiveAndConvert​(java.lang.String queueName,
                        ParameterizedTypeReference<T> type)
                 throws AmqpException
        特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        queueName - ポーリングするキューの名前
        type - 変換する型。
        戻り値:
        待っているメッセージがない場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合
        導入:
        2.0

      • receiveAndConvert

        @Nullable
<T> T receiveAndConvert​(long timeoutMillis,
                        ParameterizedTypeReference<T> type)
                 throws AmqpException
        デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。
        type - 変換する型。
        戻り値:
        期限が切れた場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合
        導入:
        2.0

      • receiveAndConvert

        @Nullable
<T> T receiveAndConvert​(java.lang.String queueName,
                        long timeoutMillis,
                        ParameterizedTypeReference<T> type)
                 throws AmqpException
        特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        queueName - ポーリングするキューの名前
        timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。
        type - 変換する型。
        戻り値:
        期限が切れた場合はメッセージまたは null
        例外:
        AmqpException - 問題がある場合
        導入:
        2.0

      • receiveAndReply

        <R,​S> boolean receiveAndReply​(ReceiveAndReplyCallback<R,​S> callback)
                             throws AmqpException
        デフォルトキューからメッセージがある場合はそれを受信し、提供された ReceiveAndReplyCallback を呼び出して、callback が応答メッセージを返した場合は、MessageProperties から replyTo Address に、またはデフォルト交換とデフォルト routingKey に応答メッセージを送信します。
        型パラメーター:
        R - Message からの変換後のリクエストの型。
        S - レスポンスの型。
        パラメーター:
        callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。
        戻り値:
        true、メッセージが受信された場合
        例外:
        AmqpException - 問題がある場合

      • receiveAndReply

        <R,​S> boolean receiveAndReply​(java.lang.String queueName,
                                    ReceiveAndReplyCallback<R,​S> callback)
                             throws AmqpException
        指定されたキューからメッセージがある場合はそれを受信し、指定された ReceiveAndReplyCallback を呼び出して、callback が応答メッセージを返した場合は、MessageProperties から replyTo Address に、またはデフォルトの交換とデフォルトの routingKey に応答メッセージを送信します。
        型パラメーター:
        R - Message からの変換後のリクエストの型。
        S - レスポンスの型。
        パラメーター:
        queueName - メッセージを受信するキュー名。
        callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。
        戻り値:
        true、メッセージが受信された場合。
        例外:
        AmqpException - 問題がある場合。

      • receiveAndReply

        <R,​S> boolean receiveAndReply​(ReceiveAndReplyCallback<R,​S> callback,
                                    java.lang.String replyExchange,
                                    java.lang.String replyRoutingKey)
                             throws AmqpException
        デフォルトキューからメッセージがある場合はメッセージを受信し、提供された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、提供された exchange および routingKey に応答メッセージを送信します。
        型パラメーター:
        R - Message からの変換後のリクエストの型。
        S - レスポンスの型。
        パラメーター:
        callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。
        replyExchange - 返信メッセージを送信する交換名。
        replyRoutingKey - 応答メッセージを送信するためのルーティングキー。
        戻り値:
        true、メッセージが受信された場合。
        例外:
        AmqpException - 問題がある場合。

      • receiveAndReply

        <R,​S> boolean receiveAndReply​(java.lang.String queueName,
                                    ReceiveAndReplyCallback<R,​S> callback,
                                    java.lang.String replyExchange,
                                    java.lang.String replyRoutingKey)
                             throws AmqpException
        提供されたキューからメッセージがある場合はメッセージを受信し、提供された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、提供された exchange および routingKey に応答メッセージを送信します。
        型パラメーター:
        R - Message からの変換後のリクエストの型。
        S - レスポンスの型。
        パラメーター:
        queueName - メッセージを受信するキュー名。
        callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。
        replyExchange - 返信メッセージを送信する交換名。
        replyRoutingKey - 応答メッセージを送信するためのルーティングキー。
        戻り値:
        true、メッセージが受信された場合
        例外:
        AmqpException - 問題がある場合

      • receiveAndReply

        <R,​S> boolean receiveAndReply​(ReceiveAndReplyCallback<R,​S> callback,
                                    ReplyToAddressCallback<S> replyToAddressCallback)
                             throws AmqpException
        デフォルトのキューからメッセージがあれば受信し、提供された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、応答メッセージを ReplyToAddressCallback の結果から replyTo Address に送信します。
        型パラメーター:
        R - Message からの変換後のリクエストの型。
        S - レスポンスの型。
        パラメーター:
        callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。
        replyToAddressCallback - 実行時に replyTo アドレスを決定するコールバック。
        戻り値:
        true、メッセージが受信された場合。
        例外:
        AmqpException - 問題がある場合。

      • receiveAndReply

        <R,​S> boolean receiveAndReply​(java.lang.String queueName,
                                    ReceiveAndReplyCallback<R,​S> callback,
                                    ReplyToAddressCallback<S> replyToAddressCallback)
                             throws AmqpException
        指定されたキューからメッセージがあれば受信し、指定された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、応答メッセージを ReplyToAddressCallback の結果から replyTo Address に送信します。
        型パラメーター:
        R - Message からの変換後のリクエストの型。
        S - レスポンスの型。
        パラメーター:
        queueName - メッセージを受信するキュー名。
        callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。
        replyToAddressCallback - 実行時に replyTo アドレスを決定するコールバック。
        戻り値:
        true、メッセージが受信された場合
        例外:
        AmqpException - 問題がある場合

      • sendAndReceive

        @Nullable
Message sendAndReceive​(Message message)
                throws AmqpException
        基本的な RPC パターン。デフォルトのルーティングキーを使用してデフォルトの交換にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
        パラメーター:
        message - 送信するメッセージ
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合

      • sendAndReceive

        @Nullable
Message sendAndReceive​(java.lang.String routingKey,
                       Message message)
                throws AmqpException
        基本的な RPC パターン。特定のルーティングキーを使用してデフォルトの交換にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
        パラメーター:
        routingKey - ルーティングキー
        message - 送信するメッセージ
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合

      • sendAndReceive

        @Nullable
Message sendAndReceive​(java.lang.String exchange,
                       java.lang.String routingKey,
                       Message message)
                throws AmqpException
        基本的な RPC パターン。特定のルーティングキーを使用して特定の交換機にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
        パラメーター:
        exchange - 取引所の名前
        routingKey - ルーティングキー
        message - 送信するメッセージ
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合

      • convertSendAndReceive

        @Nullable
java.lang.Object convertSendAndReceive​(java.lang.Object message)
                                throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
        パラメーター:
        message - 送信するメッセージ
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合

      • convertSendAndReceive

        @Nullable
java.lang.Object convertSendAndReceive​(java.lang.String routingKey,
                                       java.lang.Object message)
                                throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
        パラメーター:
        routingKey - ルーティングキー
        message - 送信するメッセージ
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合

      • convertSendAndReceive

        @Nullable
java.lang.Object convertSendAndReceive​(java.lang.String exchange,
                                       java.lang.String routingKey,
                                       java.lang.Object message)
                                throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
        パラメーター:
        exchange - 取引所の名前
        routingKey - ルーティングキー
        message - 送信するメッセージ
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合

      • convertSendAndReceive

        @Nullable
java.lang.Object convertSendAndReceive​(java.lang.Object message,
                                       MessagePostProcessor messagePostProcessor)
                                throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
        パラメーター:
        message - 送信するメッセージ
        messagePostProcessor - 送信前にメッセージに適用するプロセッサー
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合

      • convertSendAndReceive

        @Nullable
java.lang.Object convertSendAndReceive​(java.lang.String routingKey,
                                       java.lang.Object message,
                                       MessagePostProcessor messagePostProcessor)
                                throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
        パラメーター:
        routingKey - ルーティングキー
        message - 送信するメッセージ
        messagePostProcessor - 送信前にメッセージに適用するプロセッサー
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合

      • convertSendAndReceive

        @Nullable
java.lang.Object convertSendAndReceive​(java.lang.String exchange,
                                       java.lang.String routingKey,
                                       java.lang.Object message,
                                       MessagePostProcessor messagePostProcessor)
                                throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
        パラメーター:
        exchange - 取引所の名前
        routingKey - ルーティングキー
        message - 送信するメッセージ
        messagePostProcessor - 送信前にメッセージに適用するプロセッサー
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合

      • convertSendAndReceiveAsType

        @Nullable
<T> T convertSendAndReceiveAsType​(java.lang.Object message,
                                  ParameterizedTypeReference<T> responseType)
                           throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        message - 送信するメッセージ。
        responseType - 返信を変換する型。
        戻り値:
        ある場合のレスポンス。
        例外:
        AmqpException - 問題がある場合。
        導入:
        2.0

      • convertSendAndReceiveAsType

        @Nullable
<T> T convertSendAndReceiveAsType​(java.lang.String routingKey,
                                  java.lang.Object message,
                                  ParameterizedTypeReference<T> responseType)
                           throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        routingKey - ルーティングキー
        message - 送信するメッセージ
        responseType - 返信を変換する型。
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合
        導入:
        2.0

      • convertSendAndReceiveAsType

        @Nullable
<T> T convertSendAndReceiveAsType​(java.lang.String exchange,
                                  java.lang.String routingKey,
                                  java.lang.Object message,
                                  ParameterizedTypeReference<T> responseType)
                           throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        exchange - 取引所の名前
        routingKey - ルーティングキー
        message - 送信するメッセージ
        responseType - 返信を変換する型。
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合
        導入:
        2.0

      • convertSendAndReceiveAsType

        @Nullable
<T> T convertSendAndReceiveAsType​(java.lang.Object message,
                                  MessagePostProcessor messagePostProcessor,
                                  ParameterizedTypeReference<T> responseType)
                           throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        message - 送信するメッセージ
        messagePostProcessor - 送信前にメッセージに適用するプロセッサー
        responseType - 返信を変換する型。
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合
        導入:
        2.0

      • convertSendAndReceiveAsType

        @Nullable
<T> T convertSendAndReceiveAsType​(java.lang.String routingKey,
                                  java.lang.Object message,
                                  MessagePostProcessor messagePostProcessor,
                                  ParameterizedTypeReference<T> responseType)
                           throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        routingKey - ルーティングキー
        message - 送信するメッセージ
        messagePostProcessor - 送信前にメッセージに適用するプロセッサー
        responseType - 返信を変換する型。
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合
        導入:
        2.0

      • convertSendAndReceiveAsType

        @Nullable
<T> T convertSendAndReceiveAsType​(java.lang.String exchange,
                                  java.lang.String routingKey,
                                  java.lang.Object message,
                                  MessagePostProcessor messagePostProcessor,
                                  ParameterizedTypeReference<T> responseType)
                           throws AmqpException
        変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
        型パラメーター:
        T - 型。
        パラメーター:
        exchange - 取引所の名前
        routingKey - ルーティングキー
        message - 送信するメッセージ
        messagePostProcessor - 送信前にメッセージに適用するプロセッサー
        responseType - 返信を変換する型。
        戻り値:
        ある場合のレスポンス
        例外:
        AmqpException - 問題がある場合
        導入:
        2.0