Class ChunkProcessorChunkHandler<S>
java.lang.Object
org.springframework.batch.integration.chunk.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.- Author:
- Dave Syer, Michael Minella, Mahmoud Ben Hassine
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
handleChunk
(ChunkRequest<S> chunkRequest) Handle the chunk, processing all the items and returning a response summarising the result.void
setChunkProcessor
(ChunkProcessor<S> chunkProcessor) Public setter for theChunkProcessor
.
-
Constructor Details
-
ChunkProcessorChunkHandler
public ChunkProcessorChunkHandler()
-
-
Method Details
-
afterPropertiesSet
- Specified by:
afterPropertiesSet
in interfaceorg.springframework.beans.factory.InitializingBean
- Throws:
Exception
-
setChunkProcessor
Public setter for theChunkProcessor
.- Parameters:
chunkProcessor
- the chunkProcessor to set
-
handleChunk
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 interfaceChunkHandler<S>
- Parameters:
chunkRequest
- a request containing the chunk to process- Returns:
- a response summarising the result
- Throws:
Exception
- if the handler needs to roll back a transaction and have the chunk re-delivered- See Also:
-