Class ChunkProcessorChunkHandler<S>

Type Parameters:
S - the type of the items in the chunk to be handled
All Implemented Interfaces:
ChunkHandler<S>, org.springframework.beans.factory.InitializingBean

@MessageEndpoint public class ChunkProcessorChunkHandler<S> extends Object implements ChunkHandler<S>, org.springframework.beans.factory.InitializingBean
A ChunkHandler based on a ChunkProcessor. Knows how to distinguish between a processor that is fault tolerant, and one that is not. If the processor is fault tolerant then exceptions can be propagated on the assumption that there will be a roll back and the request will be re-delivered.
Dave Syer, Michael Minella, Mahmoud Ben Hassine
  • Constructor Details

    • ChunkProcessorChunkHandler

      public ChunkProcessorChunkHandler()
  • Method Details

    • afterPropertiesSet

      public void afterPropertiesSet() throws Exception
      Specified by:
      afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
    • setChunkProcessor

      public void setChunkProcessor(ChunkProcessor<S> chunkProcessor)
      Public setter for the ChunkProcessor.
      chunkProcessor - the chunkProcessor to set
    • handleChunk

      @ServiceActivator public ChunkResponse handleChunk(ChunkRequest<S> chunkRequest) throws Exception
      Description copied from interface: ChunkHandler
      Handle the chunk, processing all the items and returning a response summarising the result. If the result is a failure then the response should say so. The handler only throws an exception if it needs to roll back a transaction and knows that the request will be re-delivered (if not to the same handler then to one processing the same Step).
      Specified by:
      handleChunk in interface ChunkHandler<S>
      chunkRequest - a request containing the chunk to process
      a response summarising the result
      Exception - if the handler needs to roll back a transaction and have the chunk re-delivered
      See Also: