パッケージ org.springframework.kafka.listener.adapter

クラス AdapterUtils

java.lang.ObjectSE
org.springframework.kafka.listener.adapter.AdapterUtils
public final class AdapterUtils extends ObjectSE
リスナーアダプターのユーティリティ。
導入:
2.5
作成者:
Gary Russell, Wang Zhiyang, Huijin Hong

  • フィールドの詳細

    • PARSER_CONTEXT

      public static final ParserContext PARSER_CONTEXT
      ! を使用したランタイム SpEL のパーサーコンテキストテンプレートプレフィックス。
      導入:
      2.2.15

  • メソッドの詳細

    • buildConsumerRecordMetadataFromArray

      @Nullable public static ObjectSE buildConsumerRecordMetadataFromArray(ObjectSE... data)
      データ内の最初の ConsumerRecord から ConsumerRecordMetadata を構築します (存在する場合)。
      パラメーター:
      data - データ配列。
      戻り値:
      メタデータ、またはデータに ConsumerRecord が含まれていない場合は null。

    • buildConsumerRecordMetadata

      @Nullable public static ConsumerRecordMetadata buildConsumerRecordMetadata(ObjectSE data)
      ConsumerRecord でなければならないデータから ConsumerRecordMetadata を構築します。
      パラメーター:
      data - レコード。
      戻り値:
      メタデータまたはデータが ConsumerRecord でない場合は null。

    • getDefaultReplyTopicExpression

      public static StringSE getDefaultReplyTopicExpression()
      SendTo 値が存在しない場合、デフォルトの式を返します。
      戻り値:
      表現。
      導入:
      2.2.15

    • isAsyncReply

      public static boolean isAsyncReply(ClassSE<?> resultType)
      戻り値の型が非同期の場合は true を返します。
      パラメーター:
      resultType - InvocableHandlerMethod 戻り値の型。
      戻り値:
      型は Mono または CompletableFuture です。
      導入:
      3.2

    • isMono

      public static boolean isMono(ClassSE<?> resultType)
      型が Mono の場合は true を返します。
      パラメーター:
      resultType - InvocableHandlerMethod 戻り値の型。
      戻り値:
      型は Mono です。
      導入:
      3.2

    • isCompletableFuture

      public static boolean isCompletableFuture(ClassSE<?> resultType)
      型が CompletableFuture の場合は true を返します。
      パラメーター:
      resultType - InvocableHandlerMethod 戻り値の型。
      戻り値:
      型は CompletableFuture です。
      導入:
      3.2

    • isKotlinContinuation

      public static boolean isKotlinContinuation(ClassSE<?> parameterType)
      型が Continuation の場合は true を返します。
      パラメーター:
      parameterType - MethodParameter パラメーター型。
      戻り値:
      型は Continuation です。
      導入:
      3.2.1