diff --git a/spring-batch-integration/pom.xml b/spring-batch-integration/pom.xml index aee24758a..696f04ce9 100644 --- a/spring-batch-integration/pom.xml +++ b/spring-batch-integration/pom.xml @@ -12,7 +12,6 @@ .. - 2.5.4.A 1.0.0.M4 @@ -84,31 +83,31 @@ org.springframework - org.springframework.context + spring-context ${spring.framework.version} compile org.springframework - org.springframework.aop + spring-aop ${spring.framework.version} compile org.springframework - org.springframework.jms + spring-jms ${spring.framework.version} compile org.springframework - org.springframework.transaction + spring-tx ${spring.framework.version} compile org.springframework - org.springframework.test + spring-test ${spring.framework.version} test diff --git a/spring-batch-integration/src/main/java/org/springframework/batch/integration/chunk/ChunkMessageChannelItemWriter.java b/spring-batch-integration/src/main/java/org/springframework/batch/integration/chunk/ChunkMessageChannelItemWriter.java index b57bc00ca..18dab17fd 100644 --- a/spring-batch-integration/src/main/java/org/springframework/batch/integration/chunk/ChunkMessageChannelItemWriter.java +++ b/spring-batch-integration/src/main/java/org/springframework/batch/integration/chunk/ChunkMessageChannelItemWriter.java @@ -153,10 +153,11 @@ public class ChunkMessageChannelItemWriter extends StepExecutionListenerSupport private boolean waitForResults() { // TODO: cumulative timeout, or throw an exception? int count = 0; - while (localState.getExpecting() > 0 && count++ < 10) { + int maxCount = 10; + while (localState.getExpecting() > 0 && count++ < maxCount) { getNextResult(100); } - return count < 10; + return count < maxCount; } /**