Class ChunkOrientedTasklet<I>

  • Type Parameters:
    I - input item type
    All Implemented Interfaces:
    Tasklet

    public class ChunkOrientedTasklet<I>
    extends java.lang.Object
    implements Tasklet
    A Tasklet implementing variations on read-process-write item handling.
    Author:
    Dave Syer
    • 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 return RepeatStatus.FINISHED if finished. If not they return RepeatStatus.CONTINUABLE. On failure throws an exception.
        Specified by:
        execute in interface Tasklet
        Parameters:
        contribution - mutable state to be passed back to update the current step execution
        chunkContext - attributes shared between invocations but not between restarts
        Returns:
        an RepeatStatus indicating whether processing is continuable. Returning null is interpreted as RepeatStatus.FINISHED
        Throws:
        java.lang.Exception - thrown if error occurs during execution.