I - The input type for the stepO - The output type for the steppublic class JsrFaultTolerantStepBuilder<I,O> extends FaultTolerantStepBuilder<I,O>
FaultTolerantStepBuilder to create JSR-352
specific ChunkProvider and ChunkProcessor supporting both the chunking
pattern defined by the spec as well as skip/retry logic.StepBuilderHelper.CommonStepPropertieschunkListenerslogger, properties| Constructor and Description |
|---|
JsrFaultTolerantStepBuilder(StepBuilder parent) |
| Modifier and Type | Method and Description |
|---|---|
TaskletStep |
build()
Build the step from the components collected by the fluent setters.
|
protected ChunkProcessor<I> |
createChunkProcessor()
Provides a JSR-352 specific implementation of a
ChunkProcessor for use
within the ChunkOrientedTasklet |
protected ChunkProvider<I> |
createChunkProvider() |
FaultTolerantStepBuilder<I,O> |
faultTolerant() |
void |
setBatchPropertyContext(BatchPropertyContext batchPropertyContext) |
backOffPolicy, createRetryOperations, createSkipPolicy, createTasklet, detectStreamInReader, getChunkMonitor, getFatalExceptionAwareProxy, getJsrRetryListeners, getRollbackClassifier, getSkipListeners, keyGenerator, listener, listener, listener, listener, listener, noRetry, noRollback, noSkip, processorNonTransactional, registerStepListenerAsSkipListener, retry, retryContextCache, retryLimit, retryPolicy, skip, skipLimit, skipPolicy, stream, transactionAttributechunk, chunk, chunkOperations, createChunkOperations, getChunkCompletionPolicy, getChunkSize, getItemListeners, getProcessor, getReader, getWriter, isReaderTransactionalQueue, listener, listener, listener, processor, processor, reader, readerIsTransactionalQueue, registerAsStreamsAndListeners, registerStepListenerAsItemListener, writerconcurrent, exceptionHandler, getExceptionHandler, getStepOperations, getStreams, getTaskExecutor, getThrottleLimit, getTransactionAttribute, registerStepListenerAsChunkListener, stepOperations, taskExecutor, throttleLimitallowStartIfComplete, enhance, getJobRepository, getName, getTransactionManager, isAllowStartIfComplete, listener, repository, startLimit, transactionManagerpublic JsrFaultTolerantStepBuilder(StepBuilder parent)
public void setBatchPropertyContext(BatchPropertyContext batchPropertyContext)
public FaultTolerantStepBuilder<I,O> faultTolerant()
faultTolerant in class SimpleStepBuilder<I,O>public TaskletStep build()
StepBuilderHelper.enhance(Step) and
then to FaultTolerantStepBuilder.createTasklet() in subclasses to create the actual tasklet.build in class FaultTolerantStepBuilder<I,O>AbstractTaskletStepBuilder.build()protected ChunkProvider<I> createChunkProvider()
createChunkProvider in class FaultTolerantStepBuilder<I,O>protected ChunkProcessor<I> createChunkProcessor()
ChunkProcessor for use
within the ChunkOrientedTaskletcreateChunkProcessor in class FaultTolerantStepBuilder<I,O>ChunkProcessorJsrFaultTolerantChunkProcessor