クラス RetryTopicConfigurationProvider

java.lang.ObjectSE
org.springframework.kafka.annotation.RetryTopicConfigurationProvider
public class RetryTopicConfigurationProvider extends ObjectSE
RetryableTopic アノテーションから、またはアノテーションが利用できない場合は Bean コンテナーからインスタンスを作成して、RetryTopicConfiguration のインスタンスを提供しようとします。

コンテナー内で Bean が見つかった場合は、提供されたトピックをそのようなインスタンスで処理する必要があるかどうかがチェックされます。

アノテーションが提供されている場合は、DltHandler アノテーション付きメソッドが検索されます。

導入:
2.7
作成者:
Tomaz Fernandes, Gary Russell, Wang Zhiyang
関連事項:

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

    • RetryTopicConfigurationProvider

      public RetryTopicConfigurationProvider(@Nullable BeanFactory beanFactory)
      提供されている Bean ファクトリとデフォルトのリゾルバーおよび Bean 式コンテキストを使用してインスタンスを構築します。
      パラメーター:
      beanFactory - Bean ファクトリ。

    • RetryTopicConfigurationProvider

      public RetryTopicConfigurationProvider(@Nullable BeanFactory beanFactory, @Nullable BeanExpressionResolver resolver, @Nullable BeanExpressionContext expressionContext)
      提供されたパラメーターを使用してインスタンスを構築します。
      パラメーター:
      beanFactory - Bean ファクトリ。
      resolver - Bean 式リゾルバー。
      expressionContext - Bean 式のコンテキスト。

  • メソッドの詳細

    • findRetryConfigurationFor

      public @Nullable RetryTopicConfiguration findRetryConfigurationFor(StringSE[] topics, MethodSE method, ObjectSE bean)

    • findRetryConfigurationFor

      public @Nullable RetryTopicConfiguration findRetryConfigurationFor(StringSE[] topics, @Nullable MethodSE method, @Nullable ClassSE<?> clazz, ObjectSE bean)
      再試行トピック構成を見つけます。
      パラメーター:
      topics - 再試行可能なトピックリスト。
      method - @RetryableTopic アノテーションを取得するメソッド。
      clazz - @RetryableTopic アノテーションを取得するクラス。
      bean - Bean。
      戻り値:
      再試行トピック構成。