Class JsrFaultTolerantStepBuilder<I,O>
- java.lang.Object
- org.springframework.batch.core.step.builder.StepBuilderHelper<AbstractTaskletStepBuilder<B>>
- org.springframework.batch.core.step.builder.AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>>
- org.springframework.batch.core.step.builder.SimpleStepBuilder<I,O>
- org.springframework.batch.core.step.builder.FaultTolerantStepBuilder<I,O>
- org.springframework.batch.core.jsr.step.builder.JsrFaultTolerantStepBuilder<I,O>
- Type Parameters:
I
- The input type for the stepO
- The output type for the step
public class JsrFaultTolerantStepBuilder<I,O> extends FaultTolerantStepBuilder<I,O>
A step builder that extends theFaultTolerantStepBuilder
to create JSR-352 specificChunkProvider
andChunkProcessor
supporting both the chunking pattern defined by the spec as well as skip/retry logic.- Author:
- Michael Minella, Chris Schaefer
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.batch.core.step.builder.StepBuilderHelper
StepBuilderHelper.CommonStepProperties
Field Summary
Fields inherited from class org.springframework.batch.core.step.builder.AbstractTaskletStepBuilder
chunkListeners
Fields inherited from class org.springframework.batch.core.step.builder.StepBuilderHelper
logger, properties
Constructor Summary
Constructors Constructor Description JsrFaultTolerantStepBuilder(StepBuilder parent)
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 aChunkProcessor
for use within theChunkOrientedTasklet
protected ChunkProvider<I>
createChunkProvider()
FaultTolerantStepBuilder<I,O>
faultTolerant()
void
setBatchPropertyContext(BatchPropertyContext batchPropertyContext)
Methods inherited from class org.springframework.batch.core.step.builder.FaultTolerantStepBuilder
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
Methods inherited from class org.springframework.batch.core.step.builder.SimpleStepBuilder
chunk, chunk, chunkOperations, createChunkOperations, getChunkCompletionPolicy, getChunkSize, getItemListeners, getProcessor, getReader, getWriter, isReaderTransactionalQueue, listener, listener, listener, processor, processor, reader, readerIsTransactionalQueue, registerAsStreamsAndListeners, registerStepListenerAsItemListener, writer
Methods inherited from class org.springframework.batch.core.step.builder.AbstractTaskletStepBuilder
concurrent, exceptionHandler, getExceptionHandler, getStepOperations, getStreams, getTaskExecutor, getThrottleLimit, getTransactionAttribute, registerStepListenerAsChunkListener, stepOperations, taskExecutor, throttleLimit
Methods inherited from class org.springframework.batch.core.step.builder.StepBuilderHelper
allowStartIfComplete, enhance, getJobRepository, getName, getTransactionManager, isAllowStartIfComplete, listener, repository, startLimit, transactionManager
Constructor Detail
JsrFaultTolerantStepBuilder
public JsrFaultTolerantStepBuilder(StepBuilder parent)
Method Detail
setBatchPropertyContext
public void setBatchPropertyContext(BatchPropertyContext batchPropertyContext)
faultTolerant
public FaultTolerantStepBuilder<I,O> faultTolerant()
- Overrides:
faultTolerant
in classSimpleStepBuilder<I,O>
build
public TaskletStep build()
Build the step from the components collected by the fluent setters. Delegates first toStepBuilderHelper.enhance(Step)
and then toFaultTolerantStepBuilder.createTasklet()
in subclasses to create the actual tasklet.- Overrides:
build
in classFaultTolerantStepBuilder<I,O>
- Returns:
- a tasklet step fully configured and read to execute
- See Also:
AbstractTaskletStepBuilder.build()
createChunkProvider
protected ChunkProvider<I> createChunkProvider()
- Overrides:
createChunkProvider
in classFaultTolerantStepBuilder<I,O>
createChunkProcessor
protected ChunkProcessor<I> createChunkProcessor()
Provides a JSR-352 specific implementation of aChunkProcessor
for use within theChunkOrientedTasklet
- Overrides:
createChunkProcessor
in classFaultTolerantStepBuilder<I,O>
- Returns:
- a JSR-352 implementation of the
ChunkProcessor
- See Also:
JsrFaultTolerantChunkProcessor