クラス RabbitMessagingTemplate

    • コンストラクターの詳細

      • RabbitMessagingTemplate

        public RabbitMessagingTemplate​(RabbitTemplate rabbitTemplate)
        使用する RabbitTemplate を使用してインスタンスを作成します。
        パラメーター:
        rabbitTemplate - テンプレート。
    • メソッドの詳細

      • setRabbitTemplate

        public void setRabbitTemplate​(RabbitTemplate rabbitTemplate)
        使用する RabbitTemplate を設定します。
        パラメーター:
        rabbitTemplate - テンプレート。
      • setUseTemplateDefaultReceiveQueue

        public void setUseTemplateDefaultReceiveQueue​(boolean useTemplateDefaultReceiveQueue)
        true の場合、このテンプレートで構成された defaultDestination の代わりに、基になる RabbitTemplate の defaultReceiveQueue プロパティ (構成されている場合) を受信専用メソッドに使用します。代わりにテンプレートのキューを使用するには、これを true に設定します。デフォルトは false ですが、将来のリリースでは true になる予定です。
        パラメーター:
        useTemplateDefaultReceiveQueue - テンプレートのキューを使用する場合は true。
        導入:
        2.2.22
      • send

        public void send​(StringSE exchange,
                         StringSE routingKey,
                         Message<?> message)
                  throws MessagingException
        インターフェースからコピーされた説明: RabbitMessageOperations
        特定のルーティングキーを使用して、特定の交換にメッセージを送信します。
        次で指定:
        インターフェース RabbitMessageOperationssend 
        パラメーター:
        exchange - 取引所の名前
        routingKey - ルーティングキー
        message - 送信するメッセージ
        例外:
        MessagingException - メッセージングの例外。
      • convertAndSend

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

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

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

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

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

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

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

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

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