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

クラス DelegatingInvocableHandler

java.lang.ObjectSE
org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
public class DelegatingInvocableHandler extends ObjectSE
メッセージペイロード型に基づいて InvocableHandlerMethod に委譲します。アノテーションの付いていない単一のパラメーター、または Payload でアノテーションが付けられたパラメーターに一致します。一致は明確でなければなりません。
作成者:
Gary Russell, Wang Zhiyang

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

  • メソッドの詳細

    • getBean

      public ObjectSE getBean()
      このハンドラーの Bean を返します。
      戻り値:
      Bean。

    • isAsyncReplies

      public boolean isAsyncReplies()
      いずれかのハンドラーメソッドに非同期応答型がある場合は true を返します。
      戻り値:
      asyncReply。
      導入:
      3.2

    • invoke

      public ObjectSE invoke(Message<?> message, ObjectSE... providedArgs) throws ExceptionSE
      指定されたメッセージでメソッドを呼び出します。
      パラメーター:
      message - メッセージ。
      providedArgs - 追加引数。
      戻り値:
      呼び出しの結果。
      例外:
      ExceptionSE - 適切な引数リゾルバーが見つからない場合、またはメソッドが例外を発生させた場合に発生します。

    • getHandlerForPayload

      protected InvocableHandlerMethod getHandlerForPayload(ClassSE<?> payloadClass)
      指定された型の InvocableHandlerMethod を判別します。
      パラメーター:
      payloadClass - ペイロードクラス。
      戻り値:
      ハンドラー。

    • findHandlerForPayload

      @Nullable protected InvocableHandlerMethod findHandlerForPayload(ClassSE<? extends ObjectSE> payloadClass)

    • matchHandlerMethod

      protected boolean matchHandlerMethod(ClassSE<?> payloadClass, InvocableHandlerMethod handler)

    • getMethodNameFor

      public StringSE getMethodNameFor(ObjectSE payload)
      このペイロードに対して呼び出されるメソッドの文字列表現を返します。
      パラメーター:
      payload - ペイロード。
      戻り値:
      メソッド名。

    • hasDefaultHandler

      public boolean hasDefaultHandler()

    • getInvocationResultFor

      @Nullable public InvocationResult getInvocationResultFor(ObjectSE result, ObjectSE inboundPayload)
      結果とペイロードを指定して、メソッド呼び出しの結果を返します。
      パラメーター:
      result - 結果。
      inboundPayload - ペイロード。
      戻り値:
      メソッド呼び出しの結果。
      導入:
      3.2