public class FaultTolerantStepBuilder<I,O> extends SimpleStepBuilder<I,O>
SimpleStepBuilder
を拡張します。StepBuilderHelper.CommonStepProperties
chunkListeners
logger, properties
修飾子 | コンストラクターと説明 |
---|---|
protected | FaultTolerantStepBuilder(SimpleStepBuilder<I, O> parent) 親のプロパティで初期化された新しいビルダーを作成します。 |
| FaultTolerantStepBuilder(StepBuilderHelper<?> parent) 親のプロパティで初期化された新しいビルダーを作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
FaultTolerantStepBuilder<I, O> | backOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy) アイテムがすぐに再試行されないようにバックオフポリシーを提供します(例: |
TaskletStep | build() 提供されるリーダー、ライター、プロセッサーでステップを構築します。 |
protected ChunkProcessor<I> | createChunkProcessor() |
protected ChunkProvider<I> | createChunkProvider() |
protected BatchRetryTemplate | createRetryOperations() |
protected SkipPolicy | createSkipPolicy() |
protected Tasklet | createTasklet() 提供されているリーダー、ライター、プロセッサーを使用して、チャンク指向の新しいタスクレットを作成します。 |
protected void | detectStreamInReader() |
FaultTolerantStepBuilder<I, O> | faultTolerant() 親メソッドをオーバーライドして、新しい FaultTolerantStepBuilder が作成されないようにします |
protected ChunkMonitor | getChunkMonitor() |
protected SkipPolicy | getFatalExceptionAwareProxy(SkipPolicy skipPolicy) SkipPolicy をラップして、既知の致命的な例外と一致させます。 |
protected java.util.Set<RetryListener> | getJsrRetryListeners() |
protected org.springframework.classify.Classifier<java.lang.Throwable,java.lang.Boolean> | getRollbackClassifier() 指定されたトランザクション属性に基づいて例外分類子を取得する簡易メソッド。 |
protected java.util.Set<SkipListener<? super I,? super O>> | getSkipListeners() |
FaultTolerantStepBuilder<I, O> | keyGenerator(KeyGenerator keyGenerator) 再試行されたアイテムを識別するためのキージェネレーターを設定します。 |
FaultTolerantStepBuilder<I, O> | listener(ChunkListener listener) チャンクリスナーを登録します。 |
SimpleStepBuilder<I, O> | listener(java.lang.Object listener) アノテーションベースのリスナー構成を使用してオブジェクトを登録します。 |
FaultTolerantStepBuilder<I, O> | listener(RetryListener listener) |
FaultTolerantStepBuilder<I, O> | listener(org.springframework.retry.RetryListener listener) 再試行リスナーを登録します。 |
FaultTolerantStepBuilder<I, O> | listener(SkipListener<? super I,? super O> listener) スキップリスナーを登録します。 |
FaultTolerantStepBuilder<I, O> | noRetry(java.lang.Class<? extends java.lang.Throwable> type) 再試行から除外する例外(およびサブクラス)を明示的に要求します。 |
FaultTolerantStepBuilder<I, O> | noRollback(java.lang.Class<? extends java.lang.Throwable> type) アイテムの読み取りまたは処理中に、この例外を無視可能としてマークします。 |
FaultTolerantStepBuilder<I, O> | noSkip(java.lang.Class<? extends java.lang.Throwable> type) 特定の例外(およびサブクラス)のスキップを明示的に防止します。 |
FaultTolerantStepBuilder<I, O> | processorNonTransactional() アイテムプロセッサーを非トランザクションとしてマークします(デフォルトは逆です)。 |
protected void | registerStepListenerAsSkipListener() |
FaultTolerantStepBuilder<I, O> | retry(java.lang.Class<? extends java.lang.Throwable> type) 再試行する例外(およびサブクラス)を明示的に要求します。 |
FaultTolerantStepBuilder<I, O> | retryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache) 明示的な再試行コンテキストキャッシュを提供します。 |
FaultTolerantStepBuilder<I, O> | retryLimit(int retryLimit) 失敗したアイテムを試行する最大回数。 |
FaultTolerantStepBuilder<I, O> | retryPolicy(org.springframework.retry.RetryPolicy retryPolicy) 他の場所で提供される retryLimit(int) および再試行可能な例外を使用する代わりに、明示的な再試行ポリシーを提供します。 |
FaultTolerantStepBuilder<I, O> | skip(java.lang.Class<? extends java.lang.Throwable> type) 特定の例外(およびサブクラス)をスキップすることを明示的にリクエストします。 |
FaultTolerantStepBuilder<I, O> | skipLimit(int skipLimit) ステップが失敗する前にスキップする失敗アイテムの最大数を設定します。 |
FaultTolerantStepBuilder<I, O> | skipPolicy(SkipPolicy skipPolicy) スキップを管理するための明示的なポリシーを提供します。 |
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>> | stream(ItemStream stream) リスタートデータを管理するコールバックのストリームを登録します。 |
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>> | transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) タスクレット実行のトランザクション属性を設定します。 |
chunk, chunk, chunkOperations, createChunkOperations, getChunkCompletionPolicy, getChunkSize, getItemListeners, getProcessor, getReader, getWriter, isReaderTransactionalQueue, listener, listener, listener, processor, processor, reader, readerIsTransactionalQueue, registerAsStreamsAndListeners, registerStepListenerAsItemListener, writer
concurrent, exceptionHandler, getExceptionHandler, getStepOperations, getStreams, getTaskExecutor, getThrottleLimit, getTransactionAttribute, registerStepListenerAsChunkListener, stepOperations, taskExecutor, throttleLimit
allowStartIfComplete, enhance, getJobRepository, getName, getTransactionManager, isAllowStartIfComplete, listener, repository, startLimit, transactionManager
public FaultTolerantStepBuilder(StepBuilderHelper<?> parent)
parent
- 共通のステッププロパティを含む親ヘルパー protected FaultTolerantStepBuilder(SimpleStepBuilder<I,O> parent)
parent
- 共通のステッププロパティを含む親ヘルパー public TaskletStep build()
SimpleStepBuilder
SimpleStepBuilder<I, O>
の build
AbstractTaskletStepBuilder.build()
protected void registerStepListenerAsSkipListener()
protected Tasklet createTasklet()
SimpleStepBuilder<I, O>
の createTasklet
SimpleStepBuilder.createTasklet()
public SimpleStepBuilder<I,O> listener(java.lang.Object listener)
SimpleStepBuilder<I, O>
の listener
listener
- リスナーアノテーションで設定されたメソッドを持つオブジェクト public FaultTolerantStepBuilder<I,O> listener(SkipListener<? super I,? super O> listener)
listener
- 登録するリスナー public FaultTolerantStepBuilder<I,O> listener(RetryListener listener)
public FaultTolerantStepBuilder<I,O> listener(ChunkListener listener)
AbstractTaskletStepBuilder
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>
の listener
listener
- 登録するリスナー public AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
AbstractTaskletStepBuilder
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>
の transactionAttribute
transactionAttribute
- トランザクション属性セット public FaultTolerantStepBuilder<I,O> listener(org.springframework.retry.RetryListener listener)
listener
- 登録するリスナー public FaultTolerantStepBuilder<I,O> keyGenerator(KeyGenerator keyGenerator)
keyGenerator
- ステートフルな再試行のための鍵ジェネレーター public FaultTolerantStepBuilder<I,O> retryLimit(int retryLimit)
retryPolicy
が設定されている場合は無視されます。retryLimit
- 再試行制限 (デフォルトは 0)public FaultTolerantStepBuilder<I,O> retryPolicy(org.springframework.retry.RetryPolicy retryPolicy)
retryLimit(int)
を使用する代わりに、明示的な再試行ポリシーと、他の場所で提供される再試行可能な例外を提供します。たとえば、異なる例外を異なる回数再試行するために使用できます。retryPolicy
- 再試行ポリシー public FaultTolerantStepBuilder<I,O> backOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)
retryPolicy
が設定されている場合は無視されます。backOffPolicy
- 使用するバックオフポリシー (デフォルトではバックオフなし)public FaultTolerantStepBuilder<I,O> retryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache)
retryContextCache
- トランザクション間の再試行コンテキストのキャッシュ (デフォルトで標準のインメモリ実装に)public FaultTolerantStepBuilder<I,O> skipLimit(int skipLimit)
skipPolicy(SkipPolicy)
が提供されている場合は無視されます。skipLimit
- 設定するスキップ制限 public FaultTolerantStepBuilder<I,O> noSkip(java.lang.Class<? extends java.lang.Throwable> type)
type
- スキップ不可の例外 public FaultTolerantStepBuilder<I,O> skip(java.lang.Class<? extends java.lang.Throwable> type)
type
- 例外型。public FaultTolerantStepBuilder<I,O> skipPolicy(SkipPolicy skipPolicy)
skipPolicy
- スキップポリシー public FaultTolerantStepBuilder<I,O> noRollback(java.lang.Class<? extends java.lang.Throwable> type)
type
- ロールバックなしとしてマークする例外 public FaultTolerantStepBuilder<I,O> noRetry(java.lang.Class<? extends java.lang.Throwable> type)
type
- 再試行から除外する例外 public FaultTolerantStepBuilder<I,O> retry(java.lang.Class<? extends java.lang.Throwable> type)
type
- 再試行する例外 public FaultTolerantStepBuilder<I,O> processorNonTransactional()
public AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> stream(ItemStream stream)
AbstractTaskletStepBuilder
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>
の stream
stream
- 登録するストリーム public FaultTolerantStepBuilder<I,O> faultTolerant()
SimpleStepBuilder<I, O>
の faultTolerant
protected ChunkProvider<I> createChunkProvider()
protected ChunkProcessor<I> createChunkProcessor()
protected void detectStreamInReader()
protected org.springframework.classify.Classifier<java.lang.Throwable,java.lang.Boolean> getRollbackClassifier()
protected SkipPolicy createSkipPolicy()
protected BatchRetryTemplate createRetryOperations()
protected ChunkMonitor getChunkMonitor()
protected java.util.Set<SkipListener<? super I,? super O>> getSkipListeners()
protected java.util.Set<RetryListener> getJsrRetryListeners()
protected SkipPolicy getFatalExceptionAwareProxy(SkipPolicy skipPolicy)
SkipPolicy
をラップして、既知の致命的な例外と一致させます。skipPolicy
- 既存のスキップポリシー