From 5254865821b4a8cbc6d0521d9d31658de97b0f7f Mon Sep 17 00:00:00 2001
From: mike b <mike.baranski@gmail.com>
Date: Sun, 15 Mar 2020 14:14:46 -0400
Subject: [PATCH 1/7] [BAEL-3646] Conditional Flow in Spring Batch

---
 .../ConditionalFlowApplication.java           | 18 ++++
 .../conditionalflow/NumberInfoDecider.java    | 19 +++++
 .../config/NumberInfoConfig.java              | 85 +++++++++++++++++++
 .../conditionalflow/model/NumberInfo.java     | 47 ++++++++++
 .../conditionalflow/step/NotifierTasklet.java | 14 +++
 .../step/NumberInfoClassifier.java            | 31 +++++++
 .../step/NumberInfoClassifierWithDecider.java | 15 ++++
 .../step/NumberInfoGenerator.java             | 23 +++++
 .../step/NumberInfoProcessor.java             | 17 ++++
 .../step/PrependingStdoutWriter.java          | 30 +++++++
 .../model/NumberInfoUnitTest.java             | 44 ++++++++++
 .../step/NumberInfoClassifierUnitTest.java    | 17 ++++
 .../step/NumberInfoGeneratorUnitTest.java     | 20 +++++
 13 files changed, 380 insertions(+)
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/ConditionalFlowApplication.java
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/NumberInfoDecider.java
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/config/NumberInfoConfig.java
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/model/NumberInfo.java
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/step/NotifierTasklet.java
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoGenerator.java
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoProcessor.java
 create mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
 create mode 100644 spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java
 create mode 100644 spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java
 create mode 100644 spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java

diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/ConditionalFlowApplication.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/ConditionalFlowApplication.java
new file mode 100644
index 0000000000..8b6c841b6e
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/ConditionalFlowApplication.java
@@ -0,0 +1,18 @@
+package org.baeldung.conditionalflow;
+
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ConditionalFlowApplication implements CommandLineRunner {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ConditionalFlowApplication.class, args);
+    }
+
+    @Override
+    public void run(String... args) throws Exception {
+        System.out.println("Running and exiting");
+    }
+}
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/NumberInfoDecider.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/NumberInfoDecider.java
new file mode 100644
index 0000000000..017980f1a4
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/NumberInfoDecider.java
@@ -0,0 +1,19 @@
+package org.baeldung.conditionalflow;
+
+import org.springframework.batch.core.ExitStatus;
+import org.springframework.batch.core.JobExecution;
+import org.springframework.batch.core.StepExecution;
+import org.springframework.batch.core.job.flow.FlowExecutionStatus;
+import org.springframework.batch.core.job.flow.JobExecutionDecider;
+
+public class NumberInfoDecider implements JobExecutionDecider {
+
+    @Override
+    public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecution) {
+        if(jobExecution.getExitStatus().equals("UNKNOWN")) {
+            return new FlowExecutionStatus("NOTIFY");
+        } else {
+            return null;
+        }
+    }
+}
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/config/NumberInfoConfig.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/config/NumberInfoConfig.java
new file mode 100644
index 0000000000..fd28c2291f
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/config/NumberInfoConfig.java
@@ -0,0 +1,85 @@
+package org.baeldung.conditionalflow.config;
+
+import org.baeldung.conditionalflow.NumberInfoDecider;
+import org.baeldung.conditionalflow.model.NumberInfo;
+import org.baeldung.conditionalflow.step.*;
+import org.springframework.batch.core.Job;
+import org.springframework.batch.core.Step;
+import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
+import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
+import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@EnableBatchProcessing
+public class NumberInfoConfig {
+
+    @Bean
+    @Qualifier("NotificationStep")
+    public Step notificationStep(StepBuilderFactory sbf) {
+        return sbf.get("Billing step").tasklet(new NotifierTasklet()).build();
+    }
+
+    public Step numberGeneratorStep(StepBuilderFactory sbf, int[] values, String prepend) {
+        return sbf.get("Number generator")
+                .<NumberInfo, Integer>chunk(1)
+                .reader(new NumberInfoGenerator(values))
+                .processor(new NumberInfoClassifier())
+                .writer(new PrependingStdoutWriter<>(prepend))
+                .build();
+    }
+
+    public Step numberGeneratorStepDecider(StepBuilderFactory sbf, int[] values, String prepend) {
+        return sbf.get("Number generator")
+                .<NumberInfo, Integer>chunk(1)
+                .reader(new NumberInfoGenerator(values))
+                .processor(new NumberInfoClassifierWithDecider())
+                .writer(new PrependingStdoutWriter<>(prepend))
+                .build();
+    }
+
+    @Bean
+    public Job numberGeneratorNonNotifierJob(JobBuilderFactory jobBuilderFactory,
+                                             StepBuilderFactory stepBuilderFactory,
+                                             @Qualifier("NotificationStep") Step notificationStep
+    ) {
+        int[] nonNotifierData = {-1, -2, -3};
+        Step step = numberGeneratorStep(stepBuilderFactory, nonNotifierData, "First Dataset Processor");
+        return jobBuilderFactory.get("Number generator - first dataset")
+                .start(step)
+                .on("NOTIFY").to(notificationStep)
+                .from(step).on("*").stop()
+                .end()
+                .build();
+    }
+
+    @Bean
+    public Job numberGeneratorNotifierJob(JobBuilderFactory jobBuilderFactory,
+                                          StepBuilderFactory stepBuilderFactory,
+                                          @Qualifier("NotificationStep") Step notificationStep
+    ) {
+        int[] billableData = {11, -2, -3};
+        Step dataProviderStep = numberGeneratorStep(stepBuilderFactory, billableData, "Second Dataset Processor");
+        return jobBuilderFactory.get("Number generator - second dataset")
+                .start(dataProviderStep)
+                .on("NOTIFY").to(notificationStep)
+                .end()
+                .build();
+    }
+
+    @Bean
+    public Job numberGeneratorNotifierJobWithDecider(JobBuilderFactory jobBuilderFactory,
+                                                     StepBuilderFactory stepBuilderFactory,
+                                                     @Qualifier("NotificationStep") Step notificationStep
+    ) {
+        int[] billableData = {11, -2, -3};
+        Step dataProviderStep = numberGeneratorStepDecider(stepBuilderFactory, billableData, "Third Dataset Processor");
+        return jobBuilderFactory.get("Number generator - third dataset")
+                .start(dataProviderStep)
+                .next(new NumberInfoDecider()).on("NOTIFY").to(notificationStep)
+                .end()
+                .build();
+    }
+}
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/model/NumberInfo.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/model/NumberInfo.java
new file mode 100644
index 0000000000..81bd67d2a1
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/model/NumberInfo.java
@@ -0,0 +1,47 @@
+package org.baeldung.conditionalflow.model;
+
+import java.util.Objects;
+
+public class NumberInfo {
+    private int number;
+
+    public static NumberInfo from(int number){
+        return new NumberInfo(number);
+    }
+
+    public NumberInfo(int number) {
+        this.number = number;
+    }
+
+    public boolean isPositive() {
+        return number > 0;
+    }
+
+    public boolean isEven() {
+        return number % 2 == 0;
+    }
+
+    public int getNumber() {
+        return number;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        NumberInfo that = (NumberInfo) o;
+        return number == that.number;
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(number);
+    }
+
+    @Override
+    public String toString() {
+        return "NumberInfo{" +
+                "number=" + number +
+                '}';
+    }
+}
\ No newline at end of file
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NotifierTasklet.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NotifierTasklet.java
new file mode 100644
index 0000000000..6a88edcbbe
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NotifierTasklet.java
@@ -0,0 +1,14 @@
+package org.baeldung.conditionalflow.step;
+
+import org.springframework.batch.core.StepContribution;
+import org.springframework.batch.core.scope.context.ChunkContext;
+import org.springframework.batch.core.step.tasklet.Tasklet;
+import org.springframework.batch.repeat.RepeatStatus;
+
+public class NotifierTasklet implements Tasklet {
+    @Override
+    public RepeatStatus execute(StepContribution stepContribution, ChunkContext chunkContext) throws Exception {
+        System.err.println("[" + chunkContext.getStepContext().getJobName() + "] contains interesting data!!");
+        return RepeatStatus.FINISHED;
+    }
+}
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java
new file mode 100644
index 0000000000..95b1e4d155
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java
@@ -0,0 +1,31 @@
+package org.baeldung.conditionalflow.step;
+
+import org.baeldung.conditionalflow.model.NumberInfo;
+import org.springframework.batch.core.ExitStatus;
+import org.springframework.batch.core.StepExecution;
+import org.springframework.batch.core.annotation.BeforeStep;
+import org.springframework.batch.core.listener.ItemListenerSupport;
+import org.springframework.batch.item.ItemProcessor;
+
+public class NumberInfoClassifier extends ItemListenerSupport<NumberInfo, Integer>
+        implements ItemProcessor<NumberInfo, Integer> {
+    private StepExecution stepExecution;
+
+    @BeforeStep
+    public void beforeStep(StepExecution stepExecution) {
+        this.stepExecution = stepExecution;
+    }
+
+    @Override
+    public void afterProcess(NumberInfo item, Integer result) {
+        super.afterProcess(item, result);
+        if (item.isPositive()) {
+            stepExecution.setExitStatus(new ExitStatus("NOTIFY"));
+        }
+    }
+
+    @Override
+    public Integer process(NumberInfo numberInfo) throws Exception {
+        return Integer.valueOf(numberInfo.getNumber());
+    }
+}
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
new file mode 100644
index 0000000000..0ba7fde279
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
@@ -0,0 +1,15 @@
+package org.baeldung.conditionalflow.step;
+
+import org.baeldung.conditionalflow.model.NumberInfo;
+import org.springframework.batch.core.StepExecution;
+import org.springframework.batch.item.ItemProcessor;
+
+public class NumberInfoClassifierWithDecider
+        implements ItemProcessor<NumberInfo, Integer> {
+    private StepExecution stepExecution;
+
+    @Override
+    public Integer process(NumberInfo numberInfo) throws Exception {
+        return Integer.valueOf(numberInfo.getNumber());
+    }
+}
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoGenerator.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoGenerator.java
new file mode 100644
index 0000000000..35f6c39778
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoGenerator.java
@@ -0,0 +1,23 @@
+package org.baeldung.conditionalflow.step;
+
+import org.baeldung.conditionalflow.model.NumberInfo;
+import org.springframework.batch.item.ItemReader;
+
+public class NumberInfoGenerator implements ItemReader<NumberInfo> {
+    private int[] values;
+    private int counter;
+
+    public NumberInfoGenerator(int[] values){
+        this.values = values;
+        counter = 0;
+    }
+
+    @Override
+    public NumberInfo read() {
+        if(counter == values.length){
+            return null;
+        } else {
+            return new NumberInfo(values[counter++]);
+        }
+    }
+}
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoProcessor.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoProcessor.java
new file mode 100644
index 0000000000..fe566221de
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoProcessor.java
@@ -0,0 +1,17 @@
+package org.baeldung.conditionalflow.step;
+
+import org.baeldung.conditionalflow.model.NumberInfo;
+import org.springframework.batch.core.ExitStatus;
+import org.springframework.batch.core.StepExecution;
+import org.springframework.batch.core.annotation.BeforeStep;
+import org.springframework.batch.core.listener.ItemListenerSupport;
+import org.springframework.batch.item.ItemProcessor;
+
+public class NumberInfoProcessor implements ItemProcessor<NumberInfo, Integer> {
+    private StepExecution stepExecution;
+
+    @Override
+    public Integer process(NumberInfo numberInfo) throws Exception {
+        return Integer.valueOf(numberInfo.getNumber());
+    }
+}
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
new file mode 100644
index 0000000000..8b8959d249
--- /dev/null
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
@@ -0,0 +1,30 @@
+package org.baeldung.conditionalflow.step;
+
+import org.springframework.batch.item.ItemWriter;
+
+import java.io.OutputStream;
+import java.util.List;
+
+public class PrependingStdoutWriter<T> implements ItemWriter<T> {
+    private String prependText;
+    private OutputStream writeTo;
+
+    private PrependingStdoutWriter() {
+    }
+
+    public PrependingStdoutWriter(String prependText, OutputStream os){
+        this.prependText = prependText;
+        this.writeTo = os;
+    }
+
+    public PrependingStdoutWriter(String prependText) {
+        this(prependText, System.out);
+    }
+
+    @Override
+    public void write(List<? extends T> list) throws Exception {
+        for (T listItem : list) {
+            System.out.println(prependText + " " + listItem.toString());
+        }
+    }
+}
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java
new file mode 100644
index 0000000000..cf3d361412
--- /dev/null
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java
@@ -0,0 +1,44 @@
+package org.baeldung.conditionalflow.model;
+
+import org.junit.jupiter.api.Test;
+import org.junit.runner.RunWith;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+class NumberInfoUnitTest {
+
+    @Test
+    void isPositive() {
+        assertTrue(NumberInfo.from(1).isPositive());
+        assertTrue(NumberInfo.from(11).isPositive());
+        assertFalse(NumberInfo.from(0).isPositive());
+        assertFalse(NumberInfo.from(-1).isPositive());
+        assertFalse(NumberInfo.from(-10).isPositive());
+    }
+
+    @Test
+    void isEven() {
+        assertTrue(NumberInfo.from(0).isEven());
+        assertTrue(NumberInfo.from(-2).isEven());
+        assertTrue(NumberInfo.from(2).isEven());
+        assertTrue(NumberInfo.from(-22).isEven());
+        assertTrue(NumberInfo.from(22).isEven());
+
+        assertFalse(NumberInfo.from(1).isEven());
+        assertFalse(NumberInfo.from(-1).isEven());
+
+        assertFalse(NumberInfo.from(13).isEven());
+        assertFalse(NumberInfo.from(-13).isEven());
+        assertFalse(NumberInfo.from(31).isEven());
+        assertFalse(NumberInfo.from(-51).isEven());
+    }
+
+    @Test
+    void getNumber() {
+        for(int i = -100 ; i < 100 ; i++){
+            assertEquals(i, NumberInfo.from(i).getNumber());
+        }
+    }
+}
\ No newline at end of file
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java
new file mode 100644
index 0000000000..c195740caa
--- /dev/null
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java
@@ -0,0 +1,17 @@
+package org.baeldung.conditionalflow.step;
+
+import org.baeldung.conditionalflow.model.NumberInfo;
+import org.baeldung.conditionalflow.step.NumberInfoClassifier;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class NumberInfoClassifierUnitTest {
+
+    @Test
+    void process() throws Exception {
+        NumberInfoClassifier nic = new NumberInfoClassifier();
+        assertEquals(Integer.valueOf(4), nic.process(NumberInfo.from(4)));
+        assertEquals(Integer.valueOf(-4), nic.process(NumberInfo.from(-4)));
+    }
+}
\ No newline at end of file
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
new file mode 100644
index 0000000000..3fc240bcbf
--- /dev/null
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
@@ -0,0 +1,20 @@
+package org.baeldung.conditionalflow.step;
+
+import org.baeldung.conditionalflow.model.NumberInfo;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNull;
+
+public class NumberInfoGeneratorUnitTest {
+    @Test
+    public void testGenerateNumbers() {
+        int[] numbers = new int[]{1, -2, 4, -10};
+        NumberInfoGenerator numberGenerator = new NumberInfoGenerator(numbers);
+        assertEquals(new NumberInfo(numbers[0]), numberGenerator.read());
+        assertEquals(new NumberInfo(numbers[1]), numberGenerator.read());
+        assertEquals(new NumberInfo(numbers[2]), numberGenerator.read());
+        assertEquals(new NumberInfo(numbers[3]), numberGenerator.read());
+        assertNull(numberGenerator.read());
+    }
+}
\ No newline at end of file

From 4755fff1598cedb3925e93fe3dad1337021c073c Mon Sep 17 00:00:00 2001
From: mike b <mike.baranski@gmail.com>
Date: Tue, 17 Mar 2020 10:06:34 -0400
Subject: [PATCH 2/7] [BAEL-3646] Addressing PR comments

---
 spring-batch/repository.sqlite                | Bin 49152 -> 73728 bytes
 .../ConditionalFlowApplication.java           |   5 +-
 .../conditionalflow/NumberInfoDecider.java    |  18 +++-
 .../config/NumberInfoConfig.java              |  86 ++++++++++--------
 .../conditionalflow/model/NumberInfo.java     |  18 ++--
 .../conditionalflow/step/NotifierTasklet.java |   3 +-
 .../step/NumberInfoClassifier.java            |   9 +-
 .../step/NumberInfoClassifierWithDecider.java |   8 +-
 .../step/NumberInfoGenerator.java             |   4 +-
 .../step/NumberInfoProcessor.java             |  17 ----
 .../step/PrependingStdoutWriter.java          |   9 +-
 .../DeciderJobIntegrationTest.java            |  56 ++++++++++++
 .../model/NumberInfoUnitTest.java             |  77 +++++++++++-----
 .../step/NumberInfoClassifierUnitTest.java    |   9 +-
 .../step/NumberInfoGeneratorUnitTest.java     |   8 +-
 spring-batch/xml/retryOutput.xml              |   2 +-
 16 files changed, 208 insertions(+), 121 deletions(-)
 delete mode 100644 spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoProcessor.java
 create mode 100644 spring-batch/src/test/java/org/baeldung/conditionalflow/DeciderJobIntegrationTest.java

diff --git a/spring-batch/repository.sqlite b/spring-batch/repository.sqlite
index 4456ef63cc28948e07a545a72ec1b63366e9057b..9d260fa2d1eed9ab00ea099508119d8e44235d87 100644
GIT binary patch
literal 73728
zcmeHQTWlLwdY<7$7h4MBWH+ko79J?hio!~>oZ(e8vRj%O*^DVtA*tBfG*CywLx~Z^
z;SPtE)5Si->$X7q)FuV`)YpA)Q51dZLkqNvw&|h|?Mol_ae=l#7gz+@Z6ErdGsEEw
zIlL&byRrS#=4f~>|2gM7*Z*?PslHuonnY;m#+hmgaqeY~=egey1dih`a~$^yeES~_
zUPApJ@RxVJk9h?eB7d+P`HZ_9Y;Z3XU;5L?pD(>}>0tg3=F*}62)!5l7jVW8BJi9e
z@c#1r%Gw(L;j5;4)FQWXwfvpKx5~E;tIFG+AItfQlB+2~EqAM^2p%sXDipSbLaC<Q
zRw}|?rLdc;90+%n10lCxD;G)-b5|+Vg!K;>mgZM(-sC@A8%j*MujKb@g>uQ8tjBq2
zOa?rGX3xsy%kwL5zR7>M?#fEFrtBSh=vn0)b-(PBnbA-)=jKu2()>z3&p*EE$_=fB
zL1yx0!1sP_0Q`v8C7(R`(tvDv-Cea;D%XV4ezEAT#tor*r(CHW+F20Z$yM@qa+Ro@
zjK$W4ehdhuR0_Fb;oHi#6Et5e-x4+iO>cKiLv6NAC*{L@?f&7;T{^sz=5bp%B_9aU
z;cTr725At3v^COowK=EgJ`vU*y}dZUqA2|1H(Xc_)r|*Cf4@Z^H2p&YoI@V}pLjY+
z`vU6tTD_~V?SrT{Ow{}HkVaYmox2P3E6F7P`&(l%_3J6~Q!%_ScHSXnLwHB2RAJn3
zMjuyeq@B5x+f|(QDtVjhaAWhOk%M+$D*zGtsMd13drpIgcCD1Qhkdt|o!oxW?nKZh
zYPs5e)s=;Hh?Xz!?iOf&+J{lGKW=UaFu>BD<8|CA6l+Rl#Q9#OP*X-+8HMWI!rq9F
z72eltuTst{)#{<IXQf;$-pb|gju2Gtvl46%!3&sB55TILyFKu;hKdcLn5)(f_xHA8
zCfOc9>OVlRhWIo_i0>EX=T~w${&#=f)tbGnVJ}z7?N<E;Tgzw8r)B$5m}#ip5NZc|
zP?_6KGf54GRcJ0SlTK*J5TIJC6iT-b-^mpn3II55X%uMYK4`u}4YXLcV-DKkc6lG>
zcoxlig~>q47g#^rfT<ql^1{vmq$sdyK=NePZ>YC0dn%*-;~R7HEAcr0d-}M#^r^(~
zwA!1g+Qu$)Mn|O$HtiKkFdCHd3XG{vuOEz8R-T53lYu|P9UY5?D)V!WM^Cmd(|!OG
z>`vkKekI2ib;WX?y|`OvY<;BHQ+(Kp$G4@p(DRwZXrlcPY*o<zVNGCr!MT;Mf1N*I
zjimdX7BH5FUGkkCTUmI2hCGd9C~UN?o{<fRx&G*t(EN%d@!u~GHN1YpgLc<<33w=v
z`rECpAKb5*xR+(qrb4UHO`8GfGQGc`i_3$q>|Z<kC85`D0&dn?jS{z#0Wz>o$cN`v
z?nyk?Y}d&{8#=XT>g@O7Xo(M{QMVv4Tnm)xT83{Z66GTQ82RJKZ^8?H5CKF05kLeG
z0Ym^1Km-s0L;w*$1Q3B27y&sH<`&j=4PqJ}+)_>L<SqS3J4%sMOp_B@EFII-WV|88
z(wT&+#xxR7X!Udu;z+yQ(`IK+Z#6Y1Vl1hpRV^tcl9H;Wi3D^qnRqH0Pc<Y-mD0%o
zMBHQ%JI(fSKfU@^Bau9k6Y5r?uEw=wOeLC>mQ*<-YeY?FWS-@*(KNbdKaM8X)dtW{
zOIkXuWfJu*DMnIiI+aPJNJ6e(f;tUFHo3?rk<G|&MgHUku3{`YB7g`W0*C-2fCwN0
zhyWsh2p|H803u)^Acxj=`3s2vLg|pS%U@gq5KM+Pt#}s^00bn+;Npe&f2#kViyU*2
z<H%1U{}B1J$j6c2#_C1{5CKF05kLeG0Ym^1Km-s0L;w*$1Q3B)5xBw!*Z98Wz2^tp
z_Z#|^xnR=v_wEJ^{aQHqrmqj(xEopt1>+7~*XGsGwP5h3p9hQeS|BL7Jp0=pz^Z}c
z0+CN?p%x<lW4+8;LJWrpAOeU0BJi{j*bFXli+niDUAwj%=7N0ZC;!ZS%AP-GI~A4f
z{nFi1`Cf^+{o<qZz%rcQ5)Oy2Uj4yW!(1T1+&^K@AF=08cXEZIvTZ$e<5=u=3@|Zk
z7_jB;TsKa|BWm0xYH(nH*fmK<q_S(V3Xfv*tZ6C_HA3p7PXBhyrryp9)K6$pPeE@8
zYx0^v>_C?m;YgX8(_r-TCqz4i{1i-bMhRPXb7J>I@3rdGAv!78`|1NVE5+mM7fabG
zOunUdyUj+E82)Kb4#-kZ$7W9)_D7zHJ8G|G*7O!J)V7&F>9tSy3>{8l=<0^M*pq^>
zgp;ug6nkpQsz$SL1J0g^PET2Waz(x&iw4p32gI13uAJT)pD@$Xh}~YNqZ_7Jp=O&k
za@J|7CJ|56cD+TIoAU5P?Lj-QN4-HTNTmrSo0LFZR~{0rXA(cE@uc+mvQ5U*l%)wY
zhkG=ud}bf&Epwl~j~9bOmeS)h?wiP@rUNIHw7c}!sTnGID|5kwt4*kCGSr(oR=<k+
zdfFwtXzyi7l#M27LmR58-P0B^#XgX}o-CpC1&}mtsy6j149Yhc<r+m$)#xakS6i(k
zRXY{ydZF!dkGdj>EagP(mzH!qKB1Aa=3o`Z>9wwcIDNN|t)Cw&pp>{k9r|G_GY}cV
zc^#_tp*f18oSt#8)$|U5$&`^1Y1P>zE2KkI(^G9Q<ryli%;@-Vtb~~fqmtDP4MyF;
z(MrsL@R*n-C{=}YVdjAmisr=eWGTec$!Q&KauRke6`<TkTW$F!B1>N|5g5k+FgnJL
zmH<rar<Gu^#PMkb&;}HHxE<+2a`FPhQSOMI$)uUIPMv|l<H!(~W3$nGUq2G9@rx3?
z0~49Gs!Q`r9KQ$)zw6gwp=d4pUSnRj+4F~R8qQu(fdgUK3#?bK&?5jMuwJD0|7Tp}
z-y?q+`6GD24<djFAOeU0B7g`W0*C-2fCwN0hyWsh2z)UFUJotuS69{+78W8Q>o`&1
z=L_3XGLuLo<C#PfcJd#*9&`c){R7352d@X5Kmp%C(pK_dm0w)6lk*Fc$jIpfm;V1{
z)c=36>c!ZI03v`0Ohe#X-weLWEw009E!SWwU>}g$b{%y$740%zKfhpW`R%j#OH7!{
zFMK>7_zK6r0gC>s3p|a_^Hkp-pd{#iF-pLa0skwL{{E+>?w<>UQ19=uYM89fci9|F
z4#))fsP~^}MKaCc0QLT0px{#2xy=>&Do?Mr-clQ(-oJ0B#9ElIY9ICfU=@XWf45Pa
zkH!~9AZk2;djH8rd#LxH&7{$z;_r{(9>*u4_y4bN@vn0H3Ml@sFY?w>5LS}GF0B6~
zw(?Wi^KTsOe=ykB|Gz@@|1UB9KR-9e!T*=Rq5r*NzenIN{nC2?>3x9oy98fqHsF4T
zpZGxp5CKF05qS0x_~<<3-8c}U^9KJl_FSXSEB2Ow@d5<PAeu2L4!@igN_u;fi6!X8
zmuzPM+cqFH+i>e3GxR2gaDLJRPkWsXeB@1`O<)eIyTf<cP6D-~YA0a9ZJHfwR@oNs
zz}p?YYl2;6n`mr*g1s-nb`eZnI6ps!eGQ~l@3oI1+F3Ru3GWU&enW~SL@6Vt;$k|p
zF%rk|mi@iuR4kQEq+_vcJQj~-t$(SEBxmC!L44?WBBVSK8VT~A&`<%CIz>=0bg(6-
z1v!C|3Q<~cD61V}c00!>%7kao_?}oM)o6V0Y!*T$++~+OYBr8cI5OdAeDB>~=p%}G
zc8u>~*PgwbjH+DhokjGOTIN$v#^g(h*^T@AA_BNxz)jih%xEU0*|xb1HVjaTgIx{P
zrnRbL_Wze(=U)2z<v(2dHoV{m5kLeG0Ym^1Km-s0L;w+Zu@QKbfK##_pK{+_wRTtA
z982wk4q45v&T_s96N~tr2C%xZS~b;&$^$q*pkR`-dj<qG*bx{;9VC^#wz-;pca^UA
z#g+=f%c9;sUfqbj=O3@5cbjwvxnG=Q8Y1n$`4>ANR-|cFh+1c9sZL6<4ZDa`fp~%P
z`S5V7-+PpR>(3Cj2}kRUfekKyL)b11TN2DEAD?}RI%)j#bkfWWy)^M8d#Sbm|HoY9
zv&etL4FErWv4?srJtBYzAOeU0B7g`W0*C-2fCwN0hyWt+Y$7lh3UODs?|yGCX#Wk^
ze|hWga^!zGKJppm|37;+ONhBf1P}p401-e05CKF05kLeG0Ym^1Km-thaR>xL0qPY(
z{(l@o=#B^=0*C-2fCwN0hyWsh2p|H803v`0Jo^YB|NrdQA(j9UKm-s0L;w*$1P}p4
z01-e05CKF05txR6!~a9TK=?1X$X~+)KZpP#fCwN0Uv32O{y#Xss_NXAXrHnhkI#M-
zKE0Aabgn7Lx72R8*=Q2OMHKJ<>$S|94yPEaZIc~dwrA)X>2`JdSmUHTJKpRBv>kOU
zMZEtH@BeF`4mB`&YqoQ<>1lN$Yhif*pQ_OV0P*SpW8!tBJ}2+t{eNmUo=#31(((Sk
z=i&Z8rKW7t^Z&WOrRV<z!vDlY{th1aK?D#1L;w+ZHWB#f9PV@F`EWRV_39748s-84
zHpqX%o<CyGpIR6AjlagvI^$Y%uJmG@GG&X4&9f%EUysyD-C>=x0`(JG)KkzK!kWCs
zZtbIiE=|5lcqk1<KYv2BQ&_su1FHRb@kzm~+jdY6Aa*;G*T2))aZ%MMr+*_Ei$y1J
z?UvvL<p8G0uDz_0vkn}vPF&Y4dEHt2j3=e>i)`x>&2F#L(T!oM{ad7cXyO%w&Ul4#
z0K9^5=7|U80MQER5Y=>sE^CNFIl$niyqelQZ4r~+>Sy2gn!JEmvVU<Oi{2l>J&p`<
zIW`;3!F7I=AiZVKTGgfbC5~T&h2Qn-%dqZaj<2!jZT9?OzP!6vq-?+QV!2cPpAY|n
zga7zJ1P}p401<d05coJ4`U=Ni2Wi381%82kcq%jqFcyT)E+INY@SF5`<(rnkAP^WY
zIIvh3#+<mM10}t^Nks@9^{7RdWS~P8R6?^Y7(~+_5Q7-P`3c-fC3GzHGI0Mlg*NG$
zr0x#i73fV{YDd*hh<IX}9k?E=-4^e_+a0}Y=HUm?n0$gIkQHnf!PJHG^K<b?C9Qf7
zuF%r-vus8Z-W_)Qh7?PPQbtV0#dKz4B#z@P`+Li&SSp)H$70!dEFQ~R|56!A&c;cC
z_|Wr2NO>YO668Ihp#muNtWeSgL+_b{7UTp<Dnx0)p{#a@@yz6~C}$eie<3A&W@~)H
zR#WijVo%u3$aXV1QG2wWVG#=IZ|@p3DNQghn3TX^<>o^bnQvylVS-IZx1k$n)1^D8
zgonky=wbqHFk2WGlbu&vts_-C1+h<|?Q%yY{A3{{GT+F2cSN67;F6!Z`rVh2`3B=S
z(VEccf+=d5AJJFJnNv?oBaxV$x$lbx-qMfUl-<sZW<rXMpMPBw|3F|sDGuhwYSUWR
zG5&vUj+>hc|Jw_(?8QPN0*C-2@O&e%8Cv2NfwkwZT?2Wr#mRq-@$+ldTCM_e;Qi9w
zQu$uVa{K5!=rtS&Qg`lC_WU^uBTO?Kuy``Yb3Hx&-{In|DXvS52ThHLyG^j)Zy)c&
z@3wkIob+c_1R-mjMb;Qu<8*qaMJ32=d>8J>8b@9HzgM0mC1zW&kHuDI@&zV*0MVvN
z9-5;9201<B9w<%k5Gp{WWJJoa*d#4&ut%a%FkuG}+f*<<9Ail`69jhFa6Q?0{Fs;}
z$WDcHVVe-L#=bqw#lazKOlX6QJ_Xho%(w_;mo4r+o|<V;q@1=pFT=`yhhSWqAUb!k
z?k%;~)=tE}7~K*s0F@$hC&mp)G<t1Y=-_hi3mqnm<<#`jTGd(l|DSQ;pN0SG`CbxZ
z=@0=#01<dT5Xf$YUgZ`+d(T~Cx_fwl<rm|@>8xn$?rmOQxv%8+YlRZC1>?n!7lWYr
zUms}xc}w$8_4IpstEqiJNiY!rzrd!6U$vP3xj^Wbtp7*;|ACrC)p*~~o-NR1X~Ig!
zwVvuiqqeq*PukLes&RF;9j-o#JLLb7|DV)&kpGtwQ+L=8w#E7MFy#L=lQPmSrMsKw
NenP787l;49_J3-kW;6f*

delta 620
zcmZoTz|zpbJV8o`L7#zvfd`0TKzgE%5fg*{#socPMvlpbtm2!OF~{++G4h{b;6Jlj
zaKa&eJ0nI`1`c)Kw9KO75~swH<P5L;q!bgw6pQ2(ON%rEgCrvZlT=F!0|QG-i`3*a
z3lk&rR4$<TjQr;q_|E~&IKuB{$fEAcNs<Y?Koi*ba~b&G@n7fP&A*txjX!s@U_c~4
zt2i68Dd*%1>>{kvtjxAx*5n2j7FID9W@FCD51EBorI?wmK`e1&Q6^?XPAA6@XODO<
zf2Vj)zu*u@KWA3~MrL&+;b7N5kadjw#~JvK10B4V-`<>&hk=okm6cUqo|lz@i7|Em
z?HxZs<W31N`PtduH^9d=#MK4PfQW+(Vi4FYxZpYe#0A1!5Oeo4@b3qjyOn?P{(PB0
zkSXS1)sNwtnVI2ChzvyI9|rzE;P?W?88;Av0v1Gr_;B`SL4i4Z>`kV?h-%55oY>Pn
zIjY~3$;@){#QtnPCPpR(uwi^B82C;AmF~l#v=|ucKN$FbK-?a{F2u&j!XU^{U5juE
SREis6DA0NQe_+BaAiDrUiJ;X0

diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/ConditionalFlowApplication.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/ConditionalFlowApplication.java
index 8b6c841b6e..c977d6ecab 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/ConditionalFlowApplication.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/ConditionalFlowApplication.java
@@ -1,11 +1,14 @@
 package org.baeldung.conditionalflow;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
 public class ConditionalFlowApplication implements CommandLineRunner {
+    private static Logger logger = LoggerFactory.getLogger(ConditionalFlowApplication.class);
 
     public static void main(String[] args) {
         SpringApplication.run(ConditionalFlowApplication.class, args);
@@ -13,6 +16,6 @@ public class ConditionalFlowApplication implements CommandLineRunner {
 
     @Override
     public void run(String... args) throws Exception {
-        System.out.println("Running and exiting");
+        logger.info("Running conditional flow application...");
     }
 }
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/NumberInfoDecider.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/NumberInfoDecider.java
index 017980f1a4..701011b4d3 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/NumberInfoDecider.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/NumberInfoDecider.java
@@ -1,6 +1,5 @@
 package org.baeldung.conditionalflow;
 
-import org.springframework.batch.core.ExitStatus;
 import org.springframework.batch.core.JobExecution;
 import org.springframework.batch.core.StepExecution;
 import org.springframework.batch.core.job.flow.FlowExecutionStatus;
@@ -8,12 +7,23 @@ import org.springframework.batch.core.job.flow.JobExecutionDecider;
 
 public class NumberInfoDecider implements JobExecutionDecider {
 
+    public static final String NOTIFY = "NOTIFY";
+    public static final String QUIET = "QUIET";
+
+    /**
+     * Method that determines notification status of job
+     * @return true if notifications should be sent.
+     */
+    private boolean shouldNotify() {
+        return true;
+    }
+
     @Override
     public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecution) {
-        if(jobExecution.getExitStatus().equals("UNKNOWN")) {
-            return new FlowExecutionStatus("NOTIFY");
+        if (shouldNotify()) {
+            return new FlowExecutionStatus(NOTIFY);
         } else {
-            return null;
+            return new FlowExecutionStatus(QUIET);
         }
     }
 }
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/config/NumberInfoConfig.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/config/NumberInfoConfig.java
index fd28c2291f..906a6e1d28 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/config/NumberInfoConfig.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/config/NumberInfoConfig.java
@@ -11,6 +11,9 @@ import org.springframework.batch.core.configuration.annotation.StepBuilderFactor
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+
+import static org.baeldung.conditionalflow.NumberInfoDecider.NOTIFY;
 
 @Configuration
 @EnableBatchProcessing
@@ -19,67 +22,70 @@ public class NumberInfoConfig {
     @Bean
     @Qualifier("NotificationStep")
     public Step notificationStep(StepBuilderFactory sbf) {
-        return sbf.get("Billing step").tasklet(new NotifierTasklet()).build();
+        return sbf.get("Notify step")
+            .tasklet(new NotifierTasklet())
+            .build();
     }
 
     public Step numberGeneratorStep(StepBuilderFactory sbf, int[] values, String prepend) {
         return sbf.get("Number generator")
-                .<NumberInfo, Integer>chunk(1)
-                .reader(new NumberInfoGenerator(values))
-                .processor(new NumberInfoClassifier())
-                .writer(new PrependingStdoutWriter<>(prepend))
-                .build();
+            .<NumberInfo, Integer> chunk(1)
+            .reader(new NumberInfoGenerator(values))
+            .processor(new NumberInfoClassifier())
+            .writer(new PrependingStdoutWriter<>(prepend))
+            .build();
     }
 
     public Step numberGeneratorStepDecider(StepBuilderFactory sbf, int[] values, String prepend) {
-        return sbf.get("Number generator")
-                .<NumberInfo, Integer>chunk(1)
-                .reader(new NumberInfoGenerator(values))
-                .processor(new NumberInfoClassifierWithDecider())
-                .writer(new PrependingStdoutWriter<>(prepend))
-                .build();
+        return sbf.get("Number generator decider")
+            .<NumberInfo, Integer> chunk(1)
+            .reader(new NumberInfoGenerator(values))
+            .processor(new NumberInfoClassifierWithDecider())
+            .writer(new PrependingStdoutWriter<>(prepend))
+            .build();
     }
 
     @Bean
-    public Job numberGeneratorNonNotifierJob(JobBuilderFactory jobBuilderFactory,
-                                             StepBuilderFactory stepBuilderFactory,
-                                             @Qualifier("NotificationStep") Step notificationStep
-    ) {
-        int[] nonNotifierData = {-1, -2, -3};
+    @Qualifier("first_job")
+    public Job numberGeneratorNonNotifierJob(JobBuilderFactory jobBuilderFactory, StepBuilderFactory stepBuilderFactory, @Qualifier("NotificationStep") Step notificationStep) {
+        int[] nonNotifierData = { -1, -2, -3 };
         Step step = numberGeneratorStep(stepBuilderFactory, nonNotifierData, "First Dataset Processor");
         return jobBuilderFactory.get("Number generator - first dataset")
-                .start(step)
-                .on("NOTIFY").to(notificationStep)
-                .from(step).on("*").stop()
-                .end()
-                .build();
+            .start(step)
+            .on(NOTIFY)
+            .to(notificationStep)
+            .from(step)
+            .on("*")
+            .stop()
+            .end()
+            .build();
     }
 
     @Bean
-    public Job numberGeneratorNotifierJob(JobBuilderFactory jobBuilderFactory,
-                                          StepBuilderFactory stepBuilderFactory,
-                                          @Qualifier("NotificationStep") Step notificationStep
-    ) {
-        int[] billableData = {11, -2, -3};
+    @Qualifier("second_job")
+    public Job numberGeneratorNotifierJob(JobBuilderFactory jobBuilderFactory, StepBuilderFactory stepBuilderFactory, @Qualifier("NotificationStep") Step notificationStep) {
+        int[] billableData = { 11, -2, -3 };
         Step dataProviderStep = numberGeneratorStep(stepBuilderFactory, billableData, "Second Dataset Processor");
         return jobBuilderFactory.get("Number generator - second dataset")
-                .start(dataProviderStep)
-                .on("NOTIFY").to(notificationStep)
-                .end()
-                .build();
+            .start(dataProviderStep)
+            .on(NOTIFY)
+            .to(notificationStep)
+            .end()
+            .build();
     }
 
     @Bean
-    public Job numberGeneratorNotifierJobWithDecider(JobBuilderFactory jobBuilderFactory,
-                                                     StepBuilderFactory stepBuilderFactory,
-                                                     @Qualifier("NotificationStep") Step notificationStep
-    ) {
-        int[] billableData = {11, -2, -3};
+    @Qualifier("third_job")
+    @Primary
+    public Job numberGeneratorNotifierJobWithDecider(JobBuilderFactory jobBuilderFactory, StepBuilderFactory stepBuilderFactory, @Qualifier("NotificationStep") Step notificationStep) {
+        int[] billableData = { 11, -2, -3 };
         Step dataProviderStep = numberGeneratorStepDecider(stepBuilderFactory, billableData, "Third Dataset Processor");
         return jobBuilderFactory.get("Number generator - third dataset")
-                .start(dataProviderStep)
-                .next(new NumberInfoDecider()).on("NOTIFY").to(notificationStep)
-                .end()
-                .build();
+            .start(dataProviderStep)
+            .next(new NumberInfoDecider())
+            .on(NOTIFY)
+            .to(notificationStep)
+            .end()
+            .build();
     }
 }
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/model/NumberInfo.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/model/NumberInfo.java
index 81bd67d2a1..4134974386 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/model/NumberInfo.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/model/NumberInfo.java
@@ -5,14 +5,14 @@ import java.util.Objects;
 public class NumberInfo {
     private int number;
 
-    public static NumberInfo from(int number){
-        return new NumberInfo(number);
-    }
-
     public NumberInfo(int number) {
         this.number = number;
     }
 
+    public static NumberInfo from(int number) {
+        return new NumberInfo(number);
+    }
+
     public boolean isPositive() {
         return number > 0;
     }
@@ -27,8 +27,10 @@ public class NumberInfo {
 
     @Override
     public boolean equals(Object o) {
-        if (this == o) return true;
-        if (o == null || getClass() != o.getClass()) return false;
+        if (this == o)
+            return true;
+        if (o == null || getClass() != o.getClass())
+            return false;
         NumberInfo that = (NumberInfo) o;
         return number == that.number;
     }
@@ -40,8 +42,6 @@ public class NumberInfo {
 
     @Override
     public String toString() {
-        return "NumberInfo{" +
-                "number=" + number +
-                '}';
+        return "NumberInfo{" + "number=" + number + '}';
     }
 }
\ No newline at end of file
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NotifierTasklet.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NotifierTasklet.java
index 6a88edcbbe..0d1db66fe9 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NotifierTasklet.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NotifierTasklet.java
@@ -8,7 +8,8 @@ import org.springframework.batch.repeat.RepeatStatus;
 public class NotifierTasklet implements Tasklet {
     @Override
     public RepeatStatus execute(StepContribution stepContribution, ChunkContext chunkContext) throws Exception {
-        System.err.println("[" + chunkContext.getStepContext().getJobName() + "] contains interesting data!!");
+        System.err.println("[" + chunkContext.getStepContext()
+            .getJobName() + "] contains interesting data!!");
         return RepeatStatus.FINISHED;
     }
 }
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java
index 95b1e4d155..e9bc852d56 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java
@@ -7,20 +7,23 @@ import org.springframework.batch.core.annotation.BeforeStep;
 import org.springframework.batch.core.listener.ItemListenerSupport;
 import org.springframework.batch.item.ItemProcessor;
 
-public class NumberInfoClassifier extends ItemListenerSupport<NumberInfo, Integer>
-        implements ItemProcessor<NumberInfo, Integer> {
+import static org.baeldung.conditionalflow.NumberInfoDecider.NOTIFY;
+import static org.baeldung.conditionalflow.NumberInfoDecider.QUIET;
+
+public class NumberInfoClassifier extends ItemListenerSupport<NumberInfo, Integer> implements ItemProcessor<NumberInfo, Integer> {
     private StepExecution stepExecution;
 
     @BeforeStep
     public void beforeStep(StepExecution stepExecution) {
         this.stepExecution = stepExecution;
+        this.stepExecution.setExitStatus(new ExitStatus(QUIET));
     }
 
     @Override
     public void afterProcess(NumberInfo item, Integer result) {
         super.afterProcess(item, result);
         if (item.isPositive()) {
-            stepExecution.setExitStatus(new ExitStatus("NOTIFY"));
+            stepExecution.setExitStatus(new ExitStatus(NOTIFY));
         }
     }
 
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
index 0ba7fde279..ab6e33aec1 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
@@ -1,15 +1,17 @@
 package org.baeldung.conditionalflow.step;
 
 import org.baeldung.conditionalflow.model.NumberInfo;
+import org.springframework.batch.core.ExitStatus;
 import org.springframework.batch.core.StepExecution;
+import org.springframework.batch.core.annotation.BeforeStep;
+import org.springframework.batch.core.listener.ItemListenerSupport;
 import org.springframework.batch.item.ItemProcessor;
 
-public class NumberInfoClassifierWithDecider
-        implements ItemProcessor<NumberInfo, Integer> {
-    private StepExecution stepExecution;
+public class NumberInfoClassifierWithDecider extends ItemListenerSupport<NumberInfo, Integer> implements ItemProcessor<NumberInfo, Integer> {
 
     @Override
     public Integer process(NumberInfo numberInfo) throws Exception {
         return Integer.valueOf(numberInfo.getNumber());
     }
+
 }
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoGenerator.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoGenerator.java
index 35f6c39778..606ebf6204 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoGenerator.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoGenerator.java
@@ -7,14 +7,14 @@ public class NumberInfoGenerator implements ItemReader<NumberInfo> {
     private int[] values;
     private int counter;
 
-    public NumberInfoGenerator(int[] values){
+    public NumberInfoGenerator(int[] values) {
         this.values = values;
         counter = 0;
     }
 
     @Override
     public NumberInfo read() {
-        if(counter == values.length){
+        if (counter == values.length) {
             return null;
         } else {
             return new NumberInfo(values[counter++]);
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoProcessor.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoProcessor.java
deleted file mode 100644
index fe566221de..0000000000
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoProcessor.java
+++ /dev/null
@@ -1,17 +0,0 @@
-package org.baeldung.conditionalflow.step;
-
-import org.baeldung.conditionalflow.model.NumberInfo;
-import org.springframework.batch.core.ExitStatus;
-import org.springframework.batch.core.StepExecution;
-import org.springframework.batch.core.annotation.BeforeStep;
-import org.springframework.batch.core.listener.ItemListenerSupport;
-import org.springframework.batch.item.ItemProcessor;
-
-public class NumberInfoProcessor implements ItemProcessor<NumberInfo, Integer> {
-    private StepExecution stepExecution;
-
-    @Override
-    public Integer process(NumberInfo numberInfo) throws Exception {
-        return Integer.valueOf(numberInfo.getNumber());
-    }
-}
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
index 8b8959d249..283b43f267 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
@@ -1,18 +1,15 @@
 package org.baeldung.conditionalflow.step;
 
-import org.springframework.batch.item.ItemWriter;
-
 import java.io.OutputStream;
 import java.util.List;
 
+import org.springframework.batch.item.ItemWriter;
+
 public class PrependingStdoutWriter<T> implements ItemWriter<T> {
     private String prependText;
     private OutputStream writeTo;
 
-    private PrependingStdoutWriter() {
-    }
-
-    public PrependingStdoutWriter(String prependText, OutputStream os){
+    public PrependingStdoutWriter(String prependText, OutputStream os) {
         this.prependText = prependText;
         this.writeTo = os;
     }
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/DeciderJobIntegrationTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/DeciderJobIntegrationTest.java
new file mode 100644
index 0000000000..8669264848
--- /dev/null
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/DeciderJobIntegrationTest.java
@@ -0,0 +1,56 @@
+package org.baeldung.conditionalflow;
+
+import org.baeldung.conditionalflow.config.NumberInfoConfig;
+import org.junit.After;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.batch.core.ExitStatus;
+import org.springframework.batch.core.JobExecution;
+import org.springframework.batch.core.StepExecution;
+import org.springframework.batch.test.AssertFile;
+import org.springframework.batch.test.JobLauncherTestUtils;
+import org.springframework.batch.test.JobRepositoryTestUtils;
+import org.springframework.batch.test.context.SpringBatchTest;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.test.annotation.DirtiesContext;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.TestExecutionListeners;
+import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.test.context.support.DependencyInjectionTestExecutionListener;
+import org.springframework.test.context.support.DirtiesContextTestExecutionListener;
+
+import java.util.Collection;
+import java.util.Iterator;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+@RunWith(SpringRunner.class)
+@SpringBatchTest
+@EnableAutoConfiguration
+@ContextConfiguration(classes = { NumberInfoConfig.class })
+@TestExecutionListeners({ DependencyInjectionTestExecutionListener.class, DirtiesContextTestExecutionListener.class })
+@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS)
+public class DeciderJobIntegrationTest {
+    @Autowired
+    private JobLauncherTestUtils jobLauncherTestUtils;
+
+    @Test
+    public void whenNumberGeneratorDecider_thenNotifyStepRuns() throws Exception {
+        JobExecution jobExecution = jobLauncherTestUtils.launchJob();
+        Collection<StepExecution> actualStepExecutions = jobExecution.getStepExecutions();
+        ExitStatus actualJobExitStatus = jobExecution.getExitStatus();
+
+        assertEquals(actualJobExitStatus.getExitCode().toString(), "COMPLETED");
+        assertEquals(actualStepExecutions.size(), 2);
+        boolean notifyStepDidRun = false;
+        Iterator<StepExecution> iterator = actualStepExecutions.iterator();
+        while(iterator.hasNext() && !notifyStepDidRun){
+            if(iterator.next().getStepName().equals("Notify step")){
+                notifyStepDidRun = true;
+            }
+        }
+        assertTrue(notifyStepDidRun);
+    }
+}
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java
index cf3d361412..26cd286409 100644
--- a/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java
@@ -1,44 +1,71 @@
 package org.baeldung.conditionalflow.model;
 
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
 import org.junit.jupiter.api.Test;
 import org.junit.runner.RunWith;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
-import static org.junit.jupiter.api.Assertions.*;
-
 @RunWith(SpringJUnit4ClassRunner.class)
 class NumberInfoUnitTest {
 
     @Test
-    void isPositive() {
-        assertTrue(NumberInfo.from(1).isPositive());
-        assertTrue(NumberInfo.from(11).isPositive());
-        assertFalse(NumberInfo.from(0).isPositive());
-        assertFalse(NumberInfo.from(-1).isPositive());
-        assertFalse(NumberInfo.from(-10).isPositive());
+    void whenPositive_isPositive() {
+        assertTrue(NumberInfo.from(1)
+            .isPositive());
+        assertTrue(NumberInfo.from(11)
+            .isPositive());
+        assertFalse(NumberInfo.from(0)
+            .isPositive());
     }
 
     @Test
-    void isEven() {
-        assertTrue(NumberInfo.from(0).isEven());
-        assertTrue(NumberInfo.from(-2).isEven());
-        assertTrue(NumberInfo.from(2).isEven());
-        assertTrue(NumberInfo.from(-22).isEven());
-        assertTrue(NumberInfo.from(22).isEven());
-
-        assertFalse(NumberInfo.from(1).isEven());
-        assertFalse(NumberInfo.from(-1).isEven());
-
-        assertFalse(NumberInfo.from(13).isEven());
-        assertFalse(NumberInfo.from(-13).isEven());
-        assertFalse(NumberInfo.from(31).isEven());
-        assertFalse(NumberInfo.from(-51).isEven());
+    void whenNegative_isPositive_isFalse() {
+        assertFalse(NumberInfo.from(-1)
+            .isPositive());
+        assertFalse(NumberInfo.from(-10)
+            .isPositive());
     }
 
     @Test
-    void getNumber() {
-        for(int i = -100 ; i < 100 ; i++){
-            assertEquals(i, NumberInfo.from(i).getNumber());
+    void whenEven_isEven() {
+        assertTrue(NumberInfo.from(0)
+            .isEven());
+        assertTrue(NumberInfo.from(-2)
+            .isEven());
+        assertTrue(NumberInfo.from(2)
+            .isEven());
+        assertTrue(NumberInfo.from(-22)
+            .isEven());
+        assertTrue(NumberInfo.from(22)
+            .isEven());
+    }
+
+    @Test
+    void whenOdd_isEven_isFalse() {
+
+        assertFalse(NumberInfo.from(1)
+            .isEven());
+        assertFalse(NumberInfo.from(-1)
+            .isEven());
+
+        assertFalse(NumberInfo.from(13)
+            .isEven());
+        assertFalse(NumberInfo.from(-13)
+            .isEven());
+        assertFalse(NumberInfo.from(31)
+            .isEven());
+        assertFalse(NumberInfo.from(-51)
+            .isEven());
+    }
+
+    @Test
+    void testStatic_fromMethod_equals_getNumber() {
+        for (int i = -100; i < 100; i++) {
+            assertEquals(i, NumberInfo.from(i)
+                .getNumber());
         }
     }
 }
\ No newline at end of file
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java
index c195740caa..9b490799db 100644
--- a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java
@@ -1,15 +1,14 @@
 package org.baeldung.conditionalflow.step;
 
-import org.baeldung.conditionalflow.model.NumberInfo;
-import org.baeldung.conditionalflow.step.NumberInfoClassifier;
-import org.junit.jupiter.api.Test;
+import static org.junit.jupiter.api.Assertions.assertEquals;
 
-import static org.junit.jupiter.api.Assertions.*;
+import org.baeldung.conditionalflow.model.NumberInfo;
+import org.junit.jupiter.api.Test;
 
 class NumberInfoClassifierUnitTest {
 
     @Test
-    void process() throws Exception {
+    void process_convertsToInteger() throws Exception {
         NumberInfoClassifier nic = new NumberInfoClassifier();
         assertEquals(Integer.valueOf(4), nic.process(NumberInfo.from(4)));
         assertEquals(Integer.valueOf(-4), nic.process(NumberInfo.from(-4)));
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
index 3fc240bcbf..7794003959 100644
--- a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
@@ -1,14 +1,14 @@
 package org.baeldung.conditionalflow.step;
 
-import org.baeldung.conditionalflow.model.NumberInfo;
-import org.junit.jupiter.api.Test;
-
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNull;
 
+import org.baeldung.conditionalflow.model.NumberInfo;
+import org.junit.jupiter.api.Test;
+
 public class NumberInfoGeneratorUnitTest {
     @Test
-    public void testGenerateNumbers() {
+    public void testGenerateNumbers_correctOrderAndValue() {
         int[] numbers = new int[]{1, -2, 4, -10};
         NumberInfoGenerator numberGenerator = new NumberInfoGenerator(numbers);
         assertEquals(new NumberInfo(numbers[0]), numberGenerator.read());
diff --git a/spring-batch/xml/retryOutput.xml b/spring-batch/xml/retryOutput.xml
index d30f2c4a32..c5dec44f16 100644
--- a/spring-batch/xml/retryOutput.xml
+++ b/spring-batch/xml/retryOutput.xml
@@ -1 +1 @@
-<?xml version="1.0" encoding="UTF-8"?><transactionRecord><transactionRecord><age>10</age><amount>10000.0</amount><postCode>430222</postCode><transactionDate>2015-10-31 00:00:00</transactionDate><userId>1234</userId><username>sammy</username></transactionRecord><transactionRecord><age>10</age><amount>12321.0</amount><postCode>430222</postCode><transactionDate>2015-12-03 00:00:00</transactionDate><userId>9999</userId><username>john</username></transactionRecord></transactionRecord>
\ No newline at end of file
+<?xml version="1.0" encoding="UTF-8"?><transactionRecord></transactionRecord>
\ No newline at end of file

From 1b29ede6b19b5497dee83cc2e8355cad678221b3 Mon Sep 17 00:00:00 2001
From: mike b <mike.baranski@gmail.com>
Date: Thu, 19 Mar 2020 20:15:52 -0400
Subject: [PATCH 3/7] [BAEL-3646] Fixing tests per review comments

---
 .../step/NumberInfoClassifier.java               |  3 ++-
 .../step/NumberInfoClassifierWithDecider.java    |  1 -
 .../DeciderJobIntegrationTest.java               | 16 ++++++++--------
 .../model/NumberInfoUnitTest.java                | 10 +++++-----
 .../step/NumberInfoClassifierUnitTest.java       |  2 +-
 .../step/NumberInfoGeneratorUnitTest.java        |  2 +-
 6 files changed, 17 insertions(+), 17 deletions(-)

diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java
index e9bc852d56..fdb28263e7 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifier.java
@@ -10,7 +10,8 @@ import org.springframework.batch.item.ItemProcessor;
 import static org.baeldung.conditionalflow.NumberInfoDecider.NOTIFY;
 import static org.baeldung.conditionalflow.NumberInfoDecider.QUIET;
 
-public class NumberInfoClassifier extends ItemListenerSupport<NumberInfo, Integer> implements ItemProcessor<NumberInfo, Integer> {
+public class NumberInfoClassifier extends ItemListenerSupport<NumberInfo, Integer>
+        implements ItemProcessor<NumberInfo, Integer> {
     private StepExecution stepExecution;
 
     @BeforeStep
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
index ab6e33aec1..b9d251c02d 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
@@ -13,5 +13,4 @@ public class NumberInfoClassifierWithDecider extends ItemListenerSupport<NumberI
     public Integer process(NumberInfo numberInfo) throws Exception {
         return Integer.valueOf(numberInfo.getNumber());
     }
-
 }
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/DeciderJobIntegrationTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/DeciderJobIntegrationTest.java
index 8669264848..e73cb17494 100644
--- a/spring-batch/src/test/java/org/baeldung/conditionalflow/DeciderJobIntegrationTest.java
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/DeciderJobIntegrationTest.java
@@ -1,15 +1,12 @@
 package org.baeldung.conditionalflow;
 
 import org.baeldung.conditionalflow.config.NumberInfoConfig;
-import org.junit.After;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.batch.core.ExitStatus;
 import org.springframework.batch.core.JobExecution;
 import org.springframework.batch.core.StepExecution;
-import org.springframework.batch.test.AssertFile;
 import org.springframework.batch.test.JobLauncherTestUtils;
-import org.springframework.batch.test.JobRepositoryTestUtils;
 import org.springframework.batch.test.context.SpringBatchTest;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
@@ -37,17 +34,20 @@ public class DeciderJobIntegrationTest {
     private JobLauncherTestUtils jobLauncherTestUtils;
 
     @Test
-    public void whenNumberGeneratorDecider_thenNotifyStepRuns() throws Exception {
+    public void givenNumberGeneratorDecider_whenDeciderRuns_thenStatusIsNotify() throws Exception {
         JobExecution jobExecution = jobLauncherTestUtils.launchJob();
         Collection<StepExecution> actualStepExecutions = jobExecution.getStepExecutions();
         ExitStatus actualJobExitStatus = jobExecution.getExitStatus();
 
-        assertEquals(actualJobExitStatus.getExitCode().toString(), "COMPLETED");
-        assertEquals(actualStepExecutions.size(), 2);
+        assertEquals("COMPLETED", actualJobExitStatus.getExitCode()
+            .toString());
+        assertEquals(2, actualStepExecutions.size());
         boolean notifyStepDidRun = false;
         Iterator<StepExecution> iterator = actualStepExecutions.iterator();
-        while(iterator.hasNext() && !notifyStepDidRun){
-            if(iterator.next().getStepName().equals("Notify step")){
+        while (iterator.hasNext() && !notifyStepDidRun) {
+            if (iterator.next()
+                .getStepName()
+                .equals("Notify step")) {
                 notifyStepDidRun = true;
             }
         }
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java
index 26cd286409..dc396b38da 100644
--- a/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/model/NumberInfoUnitTest.java
@@ -12,7 +12,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 class NumberInfoUnitTest {
 
     @Test
-    void whenPositive_isPositive() {
+    void givenPositive_whenFrom_isPositive() {
         assertTrue(NumberInfo.from(1)
             .isPositive());
         assertTrue(NumberInfo.from(11)
@@ -22,7 +22,7 @@ class NumberInfoUnitTest {
     }
 
     @Test
-    void whenNegative_isPositive_isFalse() {
+    void givenNegative_whenFrom_isNegative() {
         assertFalse(NumberInfo.from(-1)
             .isPositive());
         assertFalse(NumberInfo.from(-10)
@@ -30,7 +30,7 @@ class NumberInfoUnitTest {
     }
 
     @Test
-    void whenEven_isEven() {
+    void givenEven_whenFrom_isEven() {
         assertTrue(NumberInfo.from(0)
             .isEven());
         assertTrue(NumberInfo.from(-2)
@@ -44,7 +44,7 @@ class NumberInfoUnitTest {
     }
 
     @Test
-    void whenOdd_isEven_isFalse() {
+    void givenOdd_whenFrom_isOdd() {
 
         assertFalse(NumberInfo.from(1)
             .isEven());
@@ -62,7 +62,7 @@ class NumberInfoUnitTest {
     }
 
     @Test
-    void testStatic_fromMethod_equals_getNumber() {
+    void giveGeneratedInt_whenFrom_isNumberFromGenerator() {
         for (int i = -100; i < 100; i++) {
             assertEquals(i, NumberInfo.from(i)
                 .getNumber());
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java
index 9b490799db..cea0626168 100644
--- a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoClassifierUnitTest.java
@@ -8,7 +8,7 @@ import org.junit.jupiter.api.Test;
 class NumberInfoClassifierUnitTest {
 
     @Test
-    void process_convertsToInteger() throws Exception {
+    void givenNumberInfo_whenProcess_thenConvertsToInteger() throws Exception {
         NumberInfoClassifier nic = new NumberInfoClassifier();
         assertEquals(Integer.valueOf(4), nic.process(NumberInfo.from(4)));
         assertEquals(Integer.valueOf(-4), nic.process(NumberInfo.from(-4)));
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
index 7794003959..62fe35add6 100644
--- a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
@@ -8,7 +8,7 @@ import org.junit.jupiter.api.Test;
 
 public class NumberInfoGeneratorUnitTest {
     @Test
-    public void testGenerateNumbers_correctOrderAndValue() {
+    public void givenArray_whenGenerator_correctOrderAndValue() {
         int[] numbers = new int[]{1, -2, 4, -10};
         NumberInfoGenerator numberGenerator = new NumberInfoGenerator(numbers);
         assertEquals(new NumberInfo(numbers[0]), numberGenerator.read());

From 22a929dc018988f52cb41efbce9261cabb746573 Mon Sep 17 00:00:00 2001
From: mike b <mike.baranski@gmail.com>
Date: Tue, 24 Mar 2020 10:36:56 -0400
Subject: [PATCH 4/7] [BAEL-3646] addressing pr issues

---
 .../conditionalflow/step/NumberInfoClassifierWithDecider.java | 3 ---
 .../baeldung/conditionalflow/step/PrependingStdoutWriter.java | 4 +---
 .../conditionalflow/step/NumberInfoGeneratorUnitTest.java     | 3 ++-
 3 files changed, 3 insertions(+), 7 deletions(-)

diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
index b9d251c02d..4a8b7f1963 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/NumberInfoClassifierWithDecider.java
@@ -1,9 +1,6 @@
 package org.baeldung.conditionalflow.step;
 
 import org.baeldung.conditionalflow.model.NumberInfo;
-import org.springframework.batch.core.ExitStatus;
-import org.springframework.batch.core.StepExecution;
-import org.springframework.batch.core.annotation.BeforeStep;
 import org.springframework.batch.core.listener.ItemListenerSupport;
 import org.springframework.batch.item.ItemProcessor;
 
diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
index 283b43f267..c6f77df2ba 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
@@ -7,11 +7,9 @@ import org.springframework.batch.item.ItemWriter;
 
 public class PrependingStdoutWriter<T> implements ItemWriter<T> {
     private String prependText;
-    private OutputStream writeTo;
 
-    public PrependingStdoutWriter(String prependText, OutputStream os) {
+    public PrependingStdoutWriter(String prependText) {
         this.prependText = prependText;
-        this.writeTo = os;
     }
 
     public PrependingStdoutWriter(String prependText) {
diff --git a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
index 62fe35add6..90fd884674 100644
--- a/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
+++ b/spring-batch/src/test/java/org/baeldung/conditionalflow/step/NumberInfoGeneratorUnitTest.java
@@ -7,9 +7,10 @@ import org.baeldung.conditionalflow.model.NumberInfo;
 import org.junit.jupiter.api.Test;
 
 public class NumberInfoGeneratorUnitTest {
+
     @Test
     public void givenArray_whenGenerator_correctOrderAndValue() {
-        int[] numbers = new int[]{1, -2, 4, -10};
+        int[] numbers = new int[] { 1, -2, 4, -10 };
         NumberInfoGenerator numberGenerator = new NumberInfoGenerator(numbers);
         assertEquals(new NumberInfo(numbers[0]), numberGenerator.read());
         assertEquals(new NumberInfo(numbers[1]), numberGenerator.read());

From 1b00dfebc55e3b0952125e1aaaa52a664a85f80c Mon Sep 17 00:00:00 2001
From: mike b <mike.baranski@gmail.com>
Date: Tue, 24 Mar 2020 19:57:00 -0400
Subject: [PATCH 5/7] [BAEL-3646] Addressing broken PR

---
 .../conditionalflow/step/PrependingStdoutWriter.java        | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
index c6f77df2ba..913c0885a9 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
@@ -12,12 +12,8 @@ public class PrependingStdoutWriter<T> implements ItemWriter<T> {
         this.prependText = prependText;
     }
 
-    public PrependingStdoutWriter(String prependText) {
-        this(prependText, System.out);
-    }
-
     @Override
-    public void write(List<? extends T> list) throws Exception {
+    public void write(List<? extends T> list) {
         for (T listItem : list) {
             System.out.println(prependText + " " + listItem.toString());
         }

From c77e6341cc586fbd02cc2e359edbfece5b178a7d Mon Sep 17 00:00:00 2001
From: mike b <mike.baranski@gmail.com>
Date: Tue, 24 Mar 2020 20:02:23 -0400
Subject: [PATCH 6/7] [BAEL-3646] remove unused import

---
 .../baeldung/conditionalflow/step/PrependingStdoutWriter.java    | 1 -
 1 file changed, 1 deletion(-)

diff --git a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
index 913c0885a9..9ffea1e798 100644
--- a/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
+++ b/spring-batch/src/main/java/org/baeldung/conditionalflow/step/PrependingStdoutWriter.java
@@ -1,6 +1,5 @@
 package org.baeldung.conditionalflow.step;
 
-import java.io.OutputStream;
 import java.util.List;
 
 import org.springframework.batch.item.ItemWriter;

From 88ce82650e49586c7b1e35e33610fbf6ba273d81 Mon Sep 17 00:00:00 2001
From: mike b <mike.baranski@gmail.com>
Date: Wed, 25 Mar 2020 20:23:05 -0400
Subject: [PATCH 7/7] [bael-3646] trying to resolve merge conflict.

---
 spring-batch/repository.sqlite | Bin 73728 -> 73728 bytes
 1 file changed, 0 insertions(+), 0 deletions(-)

diff --git a/spring-batch/repository.sqlite b/spring-batch/repository.sqlite
index 9d260fa2d1eed9ab00ea099508119d8e44235d87..2b549352ec8073708bd085fd414ed93d189c7511 100644
GIT binary patch
delta 3276
zcmeHJUu;uV7{BNC-fPQRZd;t#GH8itU0~b2xA$M8MA_EC*xF7g!HwwX{l`k(TBI8f
z(`+%~gBrHwJoEuH@kJg?jIP5MA0!f=L>$BiBhlc4kw;9-LX?Q-oOZPulF6HKG`ZjX
zecwIj<U7CbUuQ2evlp59aFB8+iVC7<_1CemOQI>~<D;D};DI8$x%$5ATN=0#+yp;j
z`09Jy*+(O?Zit4h3z{ujW==OvS<wtdSDm<(kP{+25(&@9wyY#_amP>+l4j?0LD$8&
zA=s9n#T8Xm6q=>n9jTLre5sV5IM$sjn`8TnhV4kQWJsbWNseJEdQLV(*%1<oWyA%|
z5G8=N#ZpfG<&)*rJ&q)qvM5TH?8Fu1f-O2`OWaa5LC(pJs8{bsp5@nc`o*r$noheE
zrXvOJ*JoN}Vkys>F2^lTlgnLRKO5wK=U1u${}~p(n+$ZXe10_tN=OzCX7?P(CVLO1
z2hy3t>6#6mqJ0zqEX#&M=UZ8drm=nbdm?`#Ylh%2$pY}fz(6~^+sDE;`vx0YmY`1f
z!u~e+&R(HO<Hx!h+7>vsul6kjm&f)IJ4S6VmEYc^eb67N@41!N8oLMT=*sb@2pU83
zL}41sX)FT+AvpU|idc8UxmTVfw#VUU>M%wVyJ6|oCkV3Z`lsnALMIAOL%xU+zS+^t
zPJ$u{a_Q$Z;H7{E@e+yn5G~mF^(2vBV7dHdPbM`qm_&RMfJ(t%{Vj8b_o%vta#vGz
zxG>t*S<_TGKKvN%0in$?x7*Fr2eSwI(|eB>js9Ly(dF7AMU>$6(Jf)3shX}0v*=Ws
zU%_P-s0Y<zVcCv_Q8-W6!<l?O*>fn1jw61*0Wa9GO~}7Lh^qDN=^sq?ax?>lsW2SM
z_(=%2Icojd>mZ;UVM2$W6}Rp{#I%s`RU6@RxmE+X(S?Zi(TlUdzmva10sc0{-$sI>
zTF~Qddb^u3Dz$SPA9_teJ?8asn0xyzI5MZuY633I9dpwRjn-1k;ye(lVEH=xAU4g#
z_U~eYtBgc#=@UQrjz!sjjk#C$Ut=r3wt{v<@zv8L=u6G%KkYJ$<CPCN@K>9{jj4mt
z6YaGw@?Y;wJK&9(4N#qtNbzEgf%7xF8d|v0%7Z{d#UH(u5gu%<nJQ;_(CzhY@Z`!-
zLeGW88$YuC_1*5DAxzwFyKiLV<t1>F#WVH?a?a29n6WqEDc9d;tc$FzPi2BHqZu1T
z6On^MQ%4@;=|A%HtHoQ}xFD{2MAju?xK`C<rp^0$iW3vIS<dFi?cyZ7GWAW+tXZOE
zWU`{g$uh2P{2%3iR_>4Z2^}LoG++S7Q5=Ux(H$0YQxBt}Ud>3drr4BUrS(i19yphT
F(x1b+3nl;n

delta 2982
zcmd^AO>7%Q6y8~97dwBp)1P3s)J8415w)|s-t}%&Q8kHO$8GJD#8s(~NH^m(cG|{P
zvZ&$$;f_M8IrxCYkC4i-tqtc!z@-OBkszckRp>1TkcfmLr69qZ@g`~nDC&*2mfz3J
z?2O*e_uiYCZ<(2InG1HIHjd-EfHr>k@*#ysZP(AmT&RP{LU-eeYl%l5P<N1PE#Af_
z;s?)$@OZ*XNLW#^q)XV;;ze1~4b?OyY{gYfUJC`^ku<EESd&#vHnDEWaK$j<2`!!|
z%Cafz8ZU6}Xm<L1xmqnxzA<3hxOBWSUg#^T+PI>ceQLpsV@)zGEbFqV7z(yb-B1u*
zi)4%CscC!T4ps_g5#HBjtn1iN3w^TGW+hBLVW<g9RT_VVj(WE>`t{zxwnn?OmS`3|
zs?EII63KeDHQ7pd9x}PN-6y!ce|Xm#e&4J>K1}%sRu;H5R0Y01n(rUUr;?|0CvwAQ
za%}Gbxx{yH2nm7^2z<6n;CP<xf6MqS##hN|>OA=_-9z3kzQW{sF%R-M`8X|sd<!T;
z-YZc(K#peilGz^*Ir__+d+if$GQ89c>lj%t>qMTQ_hRJs#9?y%b_w(za`nUrlQ-^A
z86fXp$U6HwN$}!9&|e_c>=}?DvV1Ywls_GF*89jpE(|(-X9t<T7bf@bQ9BP1-*RjJ
zsBKk;%*jI2B^|YM$OB%7LLJ~V+uY4~n(>>1!`V|OQxGkt0MPx72g9>okE+EDRRdg+
z%VT?E&MK~*-OqbapgZDryS@Bqek7AiPgKS;Nm(=0=0|d$M(&R739^-HDEe6eUgf=O
zw1|98$_fIptw?ZX0lA%IrCv=9p3cK_)GXvCUs#b=$mJrl@)r_W+)rkfd?Zjj%shXL
zGt{{yL%)(6mFG&}smVP3YBL`$*G5LVToAcVfG@`(QRLw7qoH)j??^95O0-|mzD21W
zh+f;&p<2EaYT|CR(+5$0k;OVfxjzZu4+E&h+9?rLJBMt$I#ijq2P>147Os6GqVJ#2
zRl-x1H*G6ySHdMY3m?Sn)D9QT@&&8V1DVOx{(J`guM4DRc#*=Y<=nEb_K_FSQlh03
z1ixt@>Q&_X6wOHubnWi0rw4-v{u_g|Juq~BUH|#M0LbB<xVD+zQk1KY*fuu<bn|nx
zPwaxyiZU!6Io6*!nM(3}O%l=EQ(RO>>c6cBFrhbE&OawKijYgLtrObCFz3v4sza$h
z)TGA9)y3Y&yXCy(^r0w|_2mJOfmU3ZvYPJJZ`~2-kc|H8kc^Svf9UbUv73DzY=TX!
N#YFV(6CayBe*?Yuegpsj