クラス FaultTolerantStepBuilder<I,O>

メソッドの詳細

• build

  public TaskletStep build()

  クラスからコピーされた説明: SimpleStepBuilder

  提供されるリーダー、ライター、プロセッサーでステップを構築します。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の build 

  戻り値:

  完全に構成され、実行の準備ができているタスクレットステップ

  関連事項:

  • AbstractTaskletStepBuilder.build()

• registerStepListenerAsSkipListener

  protected void registerStepListenerAsSkipListener()

• createTasklet

  protected Tasklet createTasklet()

  提供されているリーダー、ライター、プロセッサーを使用して、チャンク指向の新しいタスクレットを作成します。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の createTasklet 

  関連事項:

  • SimpleStepBuilder.createTasklet()

• listener

  public FaultTolerantStepBuilder<I,O> listener(ObjectSE listener)

  アノテーションベースのリスナー構成を使用してオブジェクトを登録します。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の listener 

  パラメーター:

  listener - リスナーアノテーションで設定されたメソッドを持つオブジェクト

  戻り値:

  流れるようなチェーン用

• listener

  public FaultTolerantStepBuilder<I,O> listener(SkipListener<? super I,? super O> listener)

  スキップリスナーを登録します。

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• listener

  public FaultTolerantStepBuilder<I,O> listener(ChunkListener listener)

  クラスからコピーされた説明: AbstractTaskletStepBuilder

  チャンクリスナーを登録します。

  オーバーライド:

  クラス AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> の listener 

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• transactionAttribute

  public SimpleStepBuilder<I,O> transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)

  クラスからコピーされた説明: AbstractTaskletStepBuilder

  タスクレット実行のトランザクション属性を設定します。デフォルトはトランザクションマネージャーのデフォルト値ですが、たとえばより長いタイムアウトを提供するように操作できます。

  オーバーライド:

  クラス AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> の transactionAttribute 

  パラメーター:

  transactionAttribute - トランザクション属性セット

  戻り値:

  流れるようなチェーン用

• listener

  public FaultTolerantStepBuilder<I,O> listener(org.springframework.retry.RetryListener listener)

  再試行リスナーを登録します。

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• keyGenerator

  public FaultTolerantStepBuilder<I,O> keyGenerator(KeyGenerator keyGenerator)

  再試行されたアイテムを識別するためのキージェネレーターを設定します。トランザクションの境界を越えて再試行するには、アイテムが再び発生したときにアイテムを識別する必要があります。デフォルトの戦略では、アイテム自体を使用し、独自の実装に依存してアイテムを識別できるようにします。多くの場合、アイテムに信頼できるハッシュコードがあり、実装が等しい場合、リーダーがトランザクション対応ではなく（デフォルト）、アイテムプロセッサー自体がトランザクション対応ではない（デフォルトではない）か、新しいアイテムを作成しない限り、キージェネレーターは必要ありません。

  パラメーター:

  keyGenerator - ステートフルな再試行のための鍵ジェネレーター

  戻り値:

  流れるようなチェーン用

• retryLimit

  public FaultTolerantStepBuilder<I,O> retryLimit(int retryLimit)

  失敗した項目を試行する最大回数。0 と 1 は両方とも、1 回だけ試行し、再試行しないように変換します。明示的な retryPolicy が設定されている場合は無視されます。

  パラメーター:

  retryLimit - 再試行制限 (デフォルトは 0)

  戻り値:

  流れるようなチェーン用

• retryPolicy

  public FaultTolerantStepBuilder<I,O> retryPolicy(org.springframework.retry.RetryPolicy retryPolicy)

  retryLimit(int) を使用する代わりに、明示的な再試行ポリシーと、他の場所で提供される再試行可能な例外を提供します。たとえば、異なる例外を異なる回数再試行するために使用できます。

  パラメーター:

  retryPolicy - 再試行ポリシー

  戻り値:

  流れるようなチェーン用

• backOffPolicy

  public FaultTolerantStepBuilder<I,O> backOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)

  アイテムがすぐに再試行されるのを防ぐためのバックオフポリシーを提供します (たとえば、解決に時間がかかる可能性がある リモートリソース障害が原因で障害が発生した場合)。明示的な retryPolicy が設定されている場合は無視されます。

  パラメーター:

  backOffPolicy - 使用するバックオフポリシー (デフォルトではバックオフなし)

  戻り値:

  流れるようなチェーン用

• retryContextCache

  public FaultTolerantStepBuilder<I,O> retryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache)

  明示的な再試行コンテキストキャッシュを提供します。アイテムの処理または書き込みで障害が発生した場合、再試行はトランザクション全体でステートフルであるため、後続の再試行のコンテキストに関するいくつかの情報を保存する必要があります。

  パラメーター:

  retryContextCache - トランザクション間の再試行コンテキストのキャッシュ (デフォルトで標準のインメモリ実装に)

  戻り値:

  流れるようなチェーン用

• skipLimit

  public FaultTolerantStepBuilder<I,O> skipLimit(int skipLimit)

  ステップが失敗する前にスキップする失敗アイテムの最大数を設定します。明示的な skipPolicy(SkipPolicy) が提供されている場合は無視されます。

  パラメーター:

  skipLimit - 設定するスキップ制限

  戻り値:

  流れるようなチェーン用

• noSkip

  public FaultTolerantStepBuilder<I,O> noSkip(ClassSE<? extends ThrowableSE> type)

  特定の例外（およびサブクラス）のスキップを明示的に防止します。

  パラメーター:

  type - スキップ不可の例外

  戻り値:

  流れるようなチェーン用

• skip

  public FaultTolerantStepBuilder<I,O> skip(ClassSE<? extends ThrowableSE> type)

  特定の例外（およびサブクラス）をスキップすることを明示的にリクエストします。これらの例外（およびそのサブクラス）は、チャンク処理（読み取り、処理、書き込み）の任意のフェーズ中にスローされる可能性がありますが、ステップ実行内の読み取り、処理、書き込みのスキップのカウントが個別に行われます。

  パラメーター:

  type - 例外型。

  戻り値:

  流れるようなチェーン用

• skipPolicy

  public FaultTolerantStepBuilder<I,O> skipPolicy(SkipPolicy skipPolicy)

  スキップを管理するための明示的なポリシーを提供します。スキップポリシーは、スキップ可能な例外とその回数を決定します。

  パラメーター:

  skipPolicy - スキップポリシー

  戻り値:

  流れるようなチェーン用

• noRollback

  public FaultTolerantStepBuilder<I,O> noRollback(ClassSE<? extends ThrowableSE> type)

  アイテムの読み取りまたは処理操作中に、この例外を無視できるものとしてマークします。追加のコールバックなしで処理が続行されます（通知が必要な場合は、代わりにスキップを使用してください）。ロールバックなしでスキップおよび再試行する保証がないため、書き込み中は無視されます。

  パラメーター:

  type - ロールバックなしとしてマークする例外

  戻り値:

  流れるようなチェーン用

• noRetry

  public FaultTolerantStepBuilder<I,O> noRetry(ClassSE<? extends ThrowableSE> type)

  再試行から除外する例外（およびサブクラス）を明示的に要求します。

  パラメーター:

  type - 再試行から除外する例外

  戻り値:

  流れるようなチェーン用

• retry

  public FaultTolerantStepBuilder<I,O> retry(ClassSE<? extends ThrowableSE> type)

  再試行する例外（およびサブクラス）を明示的に要求します。

  パラメーター:

  type - 再試行する例外

  戻り値:

  流れるようなチェーン用

• processorNonTransactional

  public FaultTolerantStepBuilder<I,O> processorNonTransactional()

  アイテムプロセッサーを非トランザクションとしてマークします（デフォルトは反対です）。このフラグが設定されている場合、アイテム処理の結果は、再試行の間およびスキップ処理中にトランザクション間でキャッシュされます。それ以外の場合、プロセッサーはすべてのトランザクションで呼び出されます。

  戻り値:

  流れるようなチェーン用

• stream

  public SimpleStepBuilder<I,O> stream(ItemStream stream)

  クラスからコピーされた説明: AbstractTaskletStepBuilder

  リスタートデータを管理するコールバックのストリームを登録します。

  オーバーライド:

  クラス AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> の stream 

  パラメーター:

  stream - 登録するストリーム

  戻り値:

  流れるようなチェーン用

• faultTolerant

  public FaultTolerantStepBuilder<I,O> faultTolerant()

  親メソッドをオーバーライドして、新しい FaultTolerantStepBuilder が作成されないようにします

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の faultTolerant 

• createChunkProvider

  protected ChunkProvider<I> createChunkProvider()

• createChunkProcessor

  protected ChunkProcessor<I> createChunkProcessor()

• detectStreamInReader

  protected void detectStreamInReader()

• getRollbackClassifier

  protected org.springframework.classify.Classifier<ThrowableSE,BooleanSE> getRollbackClassifier()

  指定されたトランザクション属性に基づいて例外分類子を取得する簡易メソッド。

  戻り値:

  例外分類子: 例外によってロールバックが発生する場合は true にマップします

• createSkipPolicy

  protected SkipPolicy createSkipPolicy()

• createRetryOperations

  protected BatchRetryTemplate createRetryOperations()

  戻り値:

  アイテム処理フェーズの完全に構成された再試行テンプレート。

• getChunkMonitor

  protected ChunkMonitor getChunkMonitor()

• getSkipListeners

  protected SetSE<SkipListener<? super I,? super O>> getSkipListeners()

• getFatalExceptionAwareProxy

  protected SkipPolicy getFatalExceptionAwareProxy(SkipPolicy skipPolicy)

  SkipPolicy をラップして、既知の致命的な例外と一致させます。

  パラメーター:

  skipPolicy - 既存のスキップポリシー

  戻り値:

  致命的な例外をスキップしないスキップポリシー