diff --git a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/BatchListenerFactoryHelper.java b/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/BatchListenerFactoryHelper.java
index 6f32e93fb..0e40ab71a 100644
--- a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/BatchListenerFactoryHelper.java
+++ b/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/BatchListenerFactoryHelper.java
@@ -30,6 +30,7 @@ import org.springframework.batch.item.ItemReader;
import org.springframework.batch.item.ItemWriter;
import org.springframework.batch.item.reader.DelegatingItemReader;
import org.springframework.batch.item.writer.DelegatingItemWriter;
+import org.springframework.batch.repeat.ExitStatus;
import org.springframework.batch.repeat.RepeatContext;
import org.springframework.batch.repeat.RepeatOperations;
import org.springframework.batch.repeat.listener.RepeatListenerSupport;
@@ -116,7 +117,7 @@ class BatchListenerFactoryHelper {
* @param listeners
* @return
*/
- public RepeatOperations getStepOperations(RepeatOperations stepOperations, BatchListener[] listeners) {
+ public RepeatOperations addChunkListeners(RepeatOperations stepOperations, BatchListener[] listeners) {
final CompositeChunkListener multicaster = new CompositeChunkListener();
@@ -140,11 +141,10 @@ class BatchListenerFactoryHelper {
RepeatTemplate stepTemplate = (RepeatTemplate) stepOperations;
stepTemplate.registerListener(new RepeatListenerSupport() {
- public void open(RepeatContext context) {
+ public void before(RepeatContext context) {
multicaster.beforeChunk();
}
-
- public void close(RepeatContext context) {
+ public void after(RepeatContext context, ExitStatus result) {
multicaster.afterChunk();
}
});
diff --git a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/DefaultStepFactoryBean.java b/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/DefaultStepFactoryBean.java
index fb0c0b42c..9a15a55c8 100644
--- a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/DefaultStepFactoryBean.java
+++ b/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/DefaultStepFactoryBean.java
@@ -184,7 +184,7 @@ public class DefaultStepFactoryBean extends AbstractStepFactoryBean {
itemReader = helper.getItemReader(itemReader, listeners);
itemWriter = helper.getItemWriter(itemWriter, listeners);
stepOperations = new RepeatTemplate();
- stepOperations = (RepeatTemplate) helper.getStepOperations(stepOperations, listeners);
+ stepOperations = (RepeatTemplate) helper.addChunkListeners(stepOperations, listeners);
// In case they are used by subclasses:
setItemReader(itemReader);
diff --git a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/RepeatOperationsStepFactoryBean.java b/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/RepeatOperationsStepFactoryBean.java
index 555a6f891..1d85245af 100644
--- a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/RepeatOperationsStepFactoryBean.java
+++ b/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/RepeatOperationsStepFactoryBean.java
@@ -123,7 +123,7 @@ public class RepeatOperationsStepFactoryBean extends AbstractStepFactoryBean {
StepListener[] stepListeners = helper.getStepListeners(listeners);
itemReader = helper.getItemReader(itemReader, listeners);
itemWriter = helper.getItemWriter(itemWriter, listeners);
- RepeatOperations stepOperations = helper.getStepOperations(this.stepOperations, listeners);
+ RepeatOperations stepOperations = helper.addChunkListeners(this.stepOperations, listeners);
// In case they are used by subclasses:
setItemReader(itemReader);
diff --git a/spring-batch-samples/src/main/resources/data-source-context.xml b/spring-batch-samples/src/main/resources/data-source-context.xml
index 317bb73a4..7d0114c0c 100644
--- a/spring-batch-samples/src/main/resources/data-source-context.xml
+++ b/spring-batch-samples/src/main/resources/data-source-context.xml
@@ -61,12 +61,6 @@
-
-
-
-
-
\ No newline at end of file