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

クラス ExceptionClassifier

java.lang.ObjectSE
org.springframework.kafka.listener.KafkaExceptionLogLevelAware
org.springframework.kafka.listener.ExceptionClassifier
既知の直属サブクラス
DeadLetterPublishingRecoverer、DefaultDestinationTopicResolver、FailedRecordProcessor
public abstract class ExceptionClassifier extends KafkaExceptionLogLevelAware
例外分類をサポートします。
導入:
2.8
作成者:
Gary Russell

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

    • ExceptionClassifier

      public ExceptionClassifier()
      インスタンスを構築します。

  • メソッドの詳細

    • defaultFatalExceptionsList

      public static ListSE<ClassSE<? extends ThrowableSE>> defaultFatalExceptionsList()
      フレームワークのデフォルトの致命的な例外のリストを返します。このメソッドは呼び出しごとに新しいリストを生成するため、リストの内容を変更してもフレームワーク自体には影響しません。参考としてのみ使用してください。
      戻り値:
      デフォルトの致命的な例外リスト。

    • defaultFalse

      public void defaultFalse(boolean retainStandardFatal)
      デフォルトでは、一致しない型は true として分類されます。このメソッドを呼び出してデフォルトを false にし、オプションで暗黙的に false として分類された型を保持します。これは、分類変更メソッドを呼び出す前に呼び出す必要があります。これは、1 つ以上の標準的な致命的な例外のスーパークラスを再試行可能として分類する場合に役立ちます。
      パラメーター:
      retainStandardFatal - true を保持します。
      導入:
      3.0

    • defaultFalse

      public void defaultFalse()
      デフォルトでは、一致しない型は true として分類されます。このメソッドを呼び出してデフォルトを false にし、false として明示的に分類された型を削除します。これは、分類変更メソッドを呼び出す前に呼び出す必要があります。
      導入:
      2.8.4

    • getClassifier

      protected org.springframework.classify.BinaryExceptionClassifier getClassifier()
      例外分類子を返します。
      戻り値:
      分類器。

    • setClassifications

      public void setClassifications(MapSE<ClassSE<? extends ThrowableSE>,BooleanSE> classifications, boolean defaultValue)
      例外の分類を設定して、例外によって (使い果たされるまで) 再試行するかどうかを決定します。そうでない場合は、すぐに回復者に移動します。デフォルトでは、次の例外は再試行されません。 その他はすべて再試行されます。このメソッドを呼び出す場合、デフォルトは適用されません。
      パラメーター:
      classifications - 分類。
      defaultValue - 一致しない例外を再試行するかどうか。
      関連事項:

    • addNotRetryableExceptions

      @SafeVarargsSE public final void addNotRetryableExceptions(ClassSE<? extends ExceptionSE>... exceptionTypes)
      例外型をデフォルトリストに追加します。デフォルトでは、次の例外は再試行されません。defaultFalse() が呼び出されていない限り、他のすべては再試行されます。
      パラメーター:
      exceptionTypes - 例外の種類。
      関連事項:

    • notRetryable

      protected void notRetryable(StreamSE<ClassSE<? extends ExceptionSE>> notRetryable)
      サブクラスはこれをオーバーライドして、再試行不可能な例外の構成の通知を受け取ることができます。
      パラメーター:
      notRetryable - 再試行できない例外。
      導入:
      2.9.3

    • addRetryableExceptions

      @SafeVarargsSE public final void addRetryableExceptions(ClassSE<? extends ExceptionSE>... exceptionTypes)
      再試行できる例外型を追加します。defaultFalse() の後にこれを呼び出して、true として分類する必要がある例外型を指定します。defaultFalse() が呼び出されていない限り、他のすべては再試行されます。
      パラメーター:
      exceptionTypes - 例外の種類。
      導入:
      2.8.4
      関連事項:

    • removeClassification

      @Nullable public BooleanSE removeClassification(ClassSE<? extends ExceptionSE> exceptionType)
      構成済みリストから例外型を削除します。デフォルトでは、次の例外は再試行されません。defaultFalse() が呼び出されていない限り、他のすべては再試行されます。
      パラメーター:
      exceptionType - 例外型。
      戻り値:
      削除が成功した場合の例外の分類。それ以外の場合は null。
      導入:
      2.8.4
      関連事項: