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 181f269cb..876971734 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 @@ -46,8 +46,8 @@ public class ChunkMessageChannelItemWriter extends StepExecutionListenerSuppo } public void write(List items) throws Exception { - // Block until expecting <= throttle limit - can Spring - // Integration do that for me? + + // Block until expecting <= throttle limit while (localState.getExpecting() > throttleLimit) { getNextResult(); }