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

インターフェース AsyncAmqpTemplate

  • すべての既知の実装クラス:
    AsyncRabbitTemplate
    public interface AsyncAmqpTemplate
    このインターフェースを実装するクラスは、非同期の送受信操作を実行できます。
    導入:
    2.0
    作成者:
    Gary Russell

    • メソッドの詳細

      • 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