Class ChunkOrientedTasklet<I>
- java.lang.Object
- org.springframework.batch.core.step.item.ChunkOrientedTasklet<I>
Constructor Summary
Constructors Constructor Description ChunkOrientedTasklet(ChunkProvider<I> chunkProvider, ChunkProcessor<I> chunkProcessor)
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RepeatStatus
execute(StepContribution contribution, ChunkContext chunkContext)
Given the current context in the form of a step contribution, do whatever is necessary to process this unit inside a transaction.void
setBuffering(boolean buffering)
Flag to indicate that items should be buffered once read.
Constructor Detail
ChunkOrientedTasklet
public ChunkOrientedTasklet(ChunkProvider<I> chunkProvider, ChunkProcessor<I> chunkProcessor)
Method Detail
setBuffering
public void setBuffering(boolean buffering)
Flag to indicate that items should be buffered once read. Defaults to true, which is appropriate for forward-only, non-transactional item readers. Main (or only) use case for setting this flag to false is a transactional JMS item reader.- Parameters:
buffering
- indicator
execute
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws java.lang.Exception
Description copied from interface:Tasklet
Given the current context in the form of a step contribution, do whatever is necessary to process this unit inside a transaction. Implementations returnRepeatStatus.FINISHED
if finished. If not they returnRepeatStatus.CONTINUABLE
. On failure throws an exception.- Specified by:
execute
in interfaceTasklet
- Parameters:
contribution
- mutable state to be passed back to update the current step executionchunkContext
- attributes shared between invocations but not between restarts- Returns:
- an
RepeatStatus
indicating whether processing is continuable. Returningnull
is interpreted asRepeatStatus.FINISHED
- Throws:
java.lang.Exception
- thrown if error occurs during execution.