BATCHADM-155: Updated to support Spring Batch 2.2.0

This commit is contained in:
Michael Minella
2013-04-19 11:21:22 -05:00
committed by Michael Minella
parent 4dc5dddc16
commit 9c942734e6
19 changed files with 131 additions and 110 deletions

View File

@@ -1,5 +1,5 @@
/*
* Copyright 2006-2007 the original author or authors.
* Copyright 2006-2013 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -26,19 +26,20 @@ import org.springframework.batch.core.step.item.FaultTolerantChunkProcessor;
import org.springframework.batch.core.step.skip.NonSkippableReadException;
import org.springframework.batch.core.step.skip.SkipLimitExceededException;
import org.springframework.batch.core.step.skip.SkipListenerFailedException;
import org.springframework.batch.retry.RetryException;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.annotation.MessageEndpoint;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.retry.RetryException;
import org.springframework.util.Assert;
/**
* A {@link ChunkHandler} based on a {@link 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
*
* @author Michael Minella
*
* @param <S> the type of the items in the chunk to be handled
*/
@MessageEndpoint
@@ -50,7 +51,7 @@ public class ChunkProcessorChunkHandler<S> implements ChunkHandler<S>, Initializ
/*
* (non-Javadoc)
*
*
* @see org.springframework.beans.factory.InitializingBean#afterPropertiesSet()
*/
public void afterPropertiesSet() throws Exception {
@@ -59,7 +60,7 @@ public class ChunkProcessorChunkHandler<S> implements ChunkHandler<S>, Initializ
/**
* Public setter for the {@link ChunkProcessor}.
*
*
* @param chunkProcessor the chunkProcessor to set
*/
public void setChunkProcessor(ChunkProcessor<S> chunkProcessor) {
@@ -67,7 +68,7 @@ public class ChunkProcessorChunkHandler<S> implements ChunkHandler<S>, Initializ
}
/**
*
*
* @see ChunkHandler#handleChunk(ChunkRequest)
*/
@ServiceActivator