インターフェース AsyncAmqpTemplate

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

  • メソッドの詳細

    • send

      default CompletableFutureSE<BooleanSE> send(Message message)

    • send

      default CompletableFutureSE<BooleanSE> send(StringSE queue, Message message)

    • send

      default CompletableFutureSE<BooleanSE> send(StringSE exchange, @Nullable StringSE routingKey, Message message)

    • convertAndSend

      default CompletableFutureSE<BooleanSE> convertAndSend(ObjectSE message)

    • convertAndSend

      default CompletableFutureSE<BooleanSE> convertAndSend(StringSE queue, ObjectSE message)

    • convertAndSend

      default CompletableFutureSE<BooleanSE> convertAndSend(StringSE exchange, @Nullable StringSE routingKey, ObjectSE message)

    • convertAndSend

      default CompletableFutureSE<BooleanSE> convertAndSend(ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor)

    • convertAndSend

      default CompletableFutureSE<BooleanSE> convertAndSend(StringSE queue, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor)

    • convertAndSend

      default CompletableFutureSE<BooleanSE> convertAndSend(StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor)

    • receive

      default CompletableFutureSE<Message> receive()

    • receive

      default CompletableFutureSE<Message> receive(StringSE queueName)

    • receiveAndConvert

      default CompletableFutureSE<ObjectSE> receiveAndConvert()

    • receiveAndConvert

      default CompletableFutureSE<ObjectSE> receiveAndConvert(StringSE queueName)

    • receiveAndConvert

      default <T> CompletableFutureSE<T> receiveAndConvert(@Nullable ParameterizedTypeReference<T> type)

    • receiveAndConvert

      default <T> CompletableFutureSE<T> receiveAndConvert(StringSE queueName, @Nullable ParameterizedTypeReference<T> type)

    • receiveAndReply

      default <R,S> CompletableFutureSE<BooleanSE> receiveAndReply(ReceiveAndReplyCallback<R,S> callback)

    • receiveAndReply

      default <R,S> CompletableFutureSE<BooleanSE> receiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback)
      サーバー側 RPC 機能を実行します。リクエストメッセージには replyTo プロパティが必要です。リクエストの messageId プロパティは相関関係に使用されます。コールバックは「応答なし」を意味する応答を生成しない可能性があります。
      型パラメーター:
      R - リクエスト本体の型。
      S - レスポンス本体型
      パラメーター:
      queueName - リクエストを消費するキュー。
      callback - リクエストを処理して応答を生成するアプリケーションコールバック。
      戻り値:
      完了ステータス: エラーがなく、応答が生成された場合には true になります。

    • sendAndReceive

      CompletableFutureSE<Message> sendAndReceive(Message message)
      デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合、そのプロパティは一意である必要があります。
      パラメーター:
      message - メッセージ。
      戻り値:
      CompletableFutureSE

    • sendAndReceive

      CompletableFutureSE<Message> sendAndReceive(StringSE routingKey, Message message)
      指定されたルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合、そのプロパティは一意である必要があります。
      パラメーター:
      routingKey - ルーティングキー。
      message - メッセージ。
      戻り値:
      CompletableFutureSE

    • sendAndReceive

      CompletableFutureSE<Message> sendAndReceive(StringSE exchange, @Nullable StringSE routingKey, Message message)
      指定された交換とルーティングキーにメッセージを送信します。メッセージに correlationId プロパティが含まれている場合、そのプロパティは一意である必要があります。
      パラメーター:
      exchange - 交換。
      routingKey - ルーティングキー。
      message - メッセージ。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceive

      <C> CompletableFutureSE<C> convertSendAndReceive(ObjectSE object)
      オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      object - 変換するオブジェクト。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceive

      <C> CompletableFutureSE<C> convertSendAndReceive(StringSE routingKey, ObjectSE object)
      オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      routingKey - ルーティングキー。
      object - 変換するオブジェクト。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceive

      <C> CompletableFutureSE<C> convertSendAndReceive(StringSE exchange, @Nullable StringSE routingKey, ObjectSE object)
      オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      exchange - 交換。
      routingKey - ルーティングキー。
      object - 変換するオブジェクト。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceive

      <C> CompletableFutureSE<C> convertSendAndReceive(ObjectSE object, MessagePostProcessor messagePostProcessor)
      MessagePostProcessor を呼び出した後、オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトのエクスチェンジに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、そのプロパティは一意である必要があります。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      object - 変換するオブジェクト。
      messagePostProcessor - ポストプロセッサー。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceive

      <C> CompletableFutureSE<C> convertSendAndReceive(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor)
      オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、指定されたルーティングキーを使用してデフォルトのエクスチェンジに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、そのプロパティは一意である必要があります。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      routingKey - ルーティングキー。
      object - 変換するオブジェクト。
      messagePostProcessor - ポストプロセッサー。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceive

      <C> CompletableFutureSE<C> convertSendAndReceive(StringSE exchange, @Nullable StringSE routingKey, ObjectSE object, @Nullable MessagePostProcessor messagePostProcessor)
      Convert the object to a message and send it to the provided exchange and routing key after invoking the MessagePostProcessor . If the post-processor adds a correlationId property, it must be unique.
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      exchange - 交換
      routingKey - ルーティングキー。
      object - 変換するオブジェクト。
      messagePostProcessor - ポストプロセッサー。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceiveAsType

      <C> CompletableFutureSE<C> convertSendAndReceiveAsType(ObjectSE object, ParameterizedTypeReference<C> responseType)
      オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      object - 変換するオブジェクト。
      responseType - レスポンス型。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceiveAsType

      <C> CompletableFutureSE<C> convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)
      オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      routingKey - ルーティングキー。
      object - 変換するオブジェクト。
      responseType - レスポンス型。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceiveAsType

      <C> CompletableFutureSE<C> convertSendAndReceiveAsType(StringSE exchange, @Nullable StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)
      オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      exchange - 交換。
      routingKey - ルーティングキー。
      object - 変換するオブジェクト。
      responseType - レスポンス型。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceiveAsType

      <C> CompletableFutureSE<C> convertSendAndReceiveAsType(ObjectSE object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable ParameterizedTypeReference<C> responseType)
      MessagePostProcessor を呼び出した後、オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトのエクスチェンジに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、そのプロパティは一意である必要があります。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      object - 変換するオブジェクト。
      messagePostProcessor - ポストプロセッサー。
      responseType - レスポンス型。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceiveAsType

      <C> CompletableFutureSE<C> convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable ParameterizedTypeReference<C> responseType)
      オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、指定されたルーティングキーを使用してデフォルトのエクスチェンジに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、そのプロパティは一意である必要があります。
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      routingKey - ルーティングキー。
      object - 変換するオブジェクト。
      messagePostProcessor - ポストプロセッサー。
      responseType - レスポンス型。
      戻り値:
      CompletableFutureSE

    • convertSendAndReceiveAsType

      <C> CompletableFutureSE<C> convertSendAndReceiveAsType(StringSE exchange, @Nullable StringSE routingKey, ObjectSE object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable ParameterizedTypeReference<C> responseType)
      Convert the object to a message and send it to the provided exchange and routing key after invoking the MessagePostProcessor . If the post-processor adds a correlationId property, it must be unique.
      型パラメーター:
      C - 期待される結果型。
      パラメーター:
      exchange - 交換
      routingKey - ルーティングキー。
      object - 変換するオブジェクト。
      messagePostProcessor - ポストプロセッサー。
      responseType - レスポンス型。
      戻り値:
      CompletableFutureSE