1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.springframework.batch.sample.loop;
17
18 import org.springframework.batch.core.ExitStatus;
19 import org.springframework.batch.core.StepExecution;
20 import org.springframework.batch.core.listener.StepExecutionListenerSupport;
21 import org.springframework.batch.sample.domain.trade.internal.GeneratingTradeItemReader;
22 import org.springframework.beans.factory.InitializingBean;
23 import org.springframework.util.Assert;
24
25
26
27
28
29
30
31
32 public class GeneratingTradeResettingListener extends StepExecutionListenerSupport implements InitializingBean {
33
34 private GeneratingTradeItemReader reader;
35
36 public ExitStatus afterStep(StepExecution stepExecution) {
37 this.reader.resetCounter();
38 return null;
39 }
40
41 public void setReader(GeneratingTradeItemReader reader) {
42 this.reader = reader;
43 }
44
45 public void afterPropertiesSet() throws Exception {
46 Assert.notNull(this.reader, "The 'reader' must be set.");
47 }
48 }