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.CommonStepProperties
chunkListeners
logger, 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()
Override parent method to prevent creation of a new FaultTolerantStepBuilder
|
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, 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 JsrFaultTolerantStepBuilder(StepBuilder parent)
public void setBatchPropertyContext(BatchPropertyContext batchPropertyContext)
public FaultTolerantStepBuilder<I,O> faultTolerant()
FaultTolerantStepBuilder
faultTolerant
in class FaultTolerantStepBuilder<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 ChunkOrientedTasklet
createChunkProcessor
in class FaultTolerantStepBuilder<I,O>
ChunkProcessor
JsrFaultTolerantChunkProcessor