public class FaultTolerantStepFactoryBean<T,S> extends SimpleStepFactoryBean<T,S>
setSkipLimit(int)
を設定して、setSkippableExceptionClasses(Map)
型の例外をいくつ許容するかを設定できます。書き込み時にスキップ可能な例外は、デフォルトでトランザクションのロールバックを引き起こします。特定の例外クラスのロールバックを回避するために、トランザクション属性に「ロールバックなし」として含めます。SimpleStepFactoryBean
logger
コンストラクターと説明 |
---|
FaultTolerantStepFactoryBean() |
修飾子と型 | メソッドと説明 |
---|---|
protected void | applyConfiguration(SimpleStepBuilder<T, S> builder) |
protected SimpleStepBuilder<T, S> | createBuilder(java.lang.String name) |
void | setBackOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy) BackOffPolicy の公開 setter。 |
void | setCacheCapacity(int cacheCapacity) 再試行ポリシーのキャッシュ容量用のパブリック setter。 |
void | setKeyGenerator(KeyGenerator keyGenerator) ロールバック全体で失敗したアイテムを識別するために使用する KeyGenerator 。 |
void | setNoRollbackExceptionClasses(java.util.Collection<java.lang.Class<? extends java.lang.Throwable>> noRollbackExceptionClasses) ロールバックなしの候補である例外クラス。 |
void | setProcessorTransactional(boolean processorTransactional) |
void | setRetryableExceptionClasses(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> retryableExceptionClasses) 再試行可能な例外分類子マップのパブリック setter(スロー可能なクラスからブール値まで、true は再試行可能です)。 |
void | setRetryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache) チャンク処理の再試行のために、デフォルトの再試行コンテキストキャッシュをオーバーライドします。 |
void | setRetryLimit(int retryLimit) 再試行制限のパブリック setter。 |
void | setRetryListeners(org.springframework.retry.RetryListener... retryListeners) RetryListener のパブリック setter。 |
void | setRetryPolicy(org.springframework.retry.RetryPolicy retryPolicy) 再試行ポリシーの Setter。 |
void | setSkipLimit(int skipLimit) スキップポリシーを決定する制限。 |
void | setSkippableExceptionClasses(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> exceptionClasses) 発生したときにジョブをクラッシュさせないが、処理によって例外がスキップされたアイテムが生成される例外クラス。 |
void | setSkipPolicy(SkipPolicy skipPolicy) アイテムの処理時に例外の結果を決定する SkipPolicy 。 |
getChunkOperations, getExceptionHandler, getItemProcessor, getItemReader, getItemWriter, getListeners, getName, getObject, getObjectType, getStepOperations, getTaskExecutor, getTransactionAttribute, isReaderTransactionalQueue, isSingleton, setAllowStartIfComplete, setBeanName, setChunkCompletionPolicy, setChunkOperations, setCommitInterval, setExceptionHandler, setIsolation, setIsReaderTransactionalQueue, setItemProcessor, setItemReader, setItemWriter, setJobRepository, setListeners, setPropagation, setSingleton, setStartLimit, setStepOperations, setStreams, setTaskExecutor, setThrottleLimit, setTransactionManager, setTransactionTimeout
public void setKeyGenerator(KeyGenerator keyGenerator)
KeyGenerator
。transactional queue flag
が false(デフォルト)の場合は使用されません。keyGenerator
- 設定する KeyGenerator
public void setRetryPolicy(org.springframework.retry.RetryPolicy retryPolicy)
retryPolicy
- ステートレス RetryPolicy
public void setRetryLimit(int retryLimit)
retryLimit == 1
です。retryLimit
- 設定する再試行制限。1 以上でなければなりません。public void setCacheCapacity(int cacheCapacity)
MapRetryContextCache
の値です。setRetryContextCache(RetryContextCache)
が直接設定されている場合、このプロパティは無視されます。cacheCapacity
- 設定するキャッシュ容量 (0 より大きい場合は無視)public void setRetryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache)
setCacheCapacity(int)
は無視されます。retryContextCache
- 設定する RetryContextCache
public void setRetryableExceptionClasses(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> retryableExceptionClasses)
retryableExceptionClasses
- 設定する retryableExceptionClassespublic void setBackOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)
BackOffPolicy
の公開 setter。backOffPolicy
- 設定する BackOffPolicy
public void setRetryListeners(org.springframework.retry.RetryListener... retryListeners)
RetryListener
のパブリック setter。retryListeners
- 設定する RetryListener
public void setSkipLimit(int skipLimit)
skipLimit
- 設定する値。デフォルトは 0(スキップしない)です。public void setSkipPolicy(SkipPolicy skipPolicy)
SkipPolicy
。skipLimit
をオーバーライドします。これが設定されている場合、skippableExceptionClasses
も無視されます。skipPolicy
- 設定する SkipPolicy
public void setSkippableExceptionClasses(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> exceptionClasses)
skip limit
も設定することを忘れないでください。exceptionClasses
- デフォルトは Exception
public void setNoRollbackExceptionClasses(java.util.Collection<java.lang.Class<? extends java.lang.Throwable>> noRollbackExceptionClasses)
Step
は、すべての状況でロールバックなしのヒントを尊重できるわけではありませんが、このリストの例外はスキップ可能としてカウントされるため、ロールバックが必要な場合でも、スキップ制限に違反しない限り、ステップは失敗しません。noRollbackExceptionClasses
- 設定する例外クラス public void setProcessorTransactional(boolean processorTransactional)
processorTransactional
- ブール値は、ItemProcessor
がトランザクションに参加しているかどうかを示します。protected SimpleStepBuilder<T,S> createBuilder(java.lang.String name)
SimpleStepFactoryBean<T, S>
の createBuilder
protected void applyConfiguration(SimpleStepBuilder<T,S> builder)
SimpleStepFactoryBean<T, S>
の applyConfiguration