[BAEL-3646] Fixing tests per review comments
This commit is contained in:
parent
e58683f48b
commit
f953196ddf
@ -10,7 +10,8 @@ import org.springframework.batch.item.ItemProcessor;
|
|||||||
import static org.baeldung.conditionalflow.NumberInfoDecider.NOTIFY;
|
import static org.baeldung.conditionalflow.NumberInfoDecider.NOTIFY;
|
||||||
import static org.baeldung.conditionalflow.NumberInfoDecider.QUIET;
|
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;
|
private StepExecution stepExecution;
|
||||||
|
|
||||||
@BeforeStep
|
@BeforeStep
|
||||||
|
@ -13,5 +13,4 @@ public class NumberInfoClassifierWithDecider extends ItemListenerSupport<NumberI
|
|||||||
public Integer process(NumberInfo numberInfo) throws Exception {
|
public Integer process(NumberInfo numberInfo) throws Exception {
|
||||||
return Integer.valueOf(numberInfo.getNumber());
|
return Integer.valueOf(numberInfo.getNumber());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -1,15 +1,12 @@
|
|||||||
package org.baeldung.conditionalflow;
|
package org.baeldung.conditionalflow;
|
||||||
|
|
||||||
import org.baeldung.conditionalflow.config.NumberInfoConfig;
|
import org.baeldung.conditionalflow.config.NumberInfoConfig;
|
||||||
import org.junit.After;
|
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.junit.runner.RunWith;
|
import org.junit.runner.RunWith;
|
||||||
import org.springframework.batch.core.ExitStatus;
|
import org.springframework.batch.core.ExitStatus;
|
||||||
import org.springframework.batch.core.JobExecution;
|
import org.springframework.batch.core.JobExecution;
|
||||||
import org.springframework.batch.core.StepExecution;
|
import org.springframework.batch.core.StepExecution;
|
||||||
import org.springframework.batch.test.AssertFile;
|
|
||||||
import org.springframework.batch.test.JobLauncherTestUtils;
|
import org.springframework.batch.test.JobLauncherTestUtils;
|
||||||
import org.springframework.batch.test.JobRepositoryTestUtils;
|
|
||||||
import org.springframework.batch.test.context.SpringBatchTest;
|
import org.springframework.batch.test.context.SpringBatchTest;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
|
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
|
||||||
@ -37,17 +34,20 @@ public class DeciderJobIntegrationTest {
|
|||||||
private JobLauncherTestUtils jobLauncherTestUtils;
|
private JobLauncherTestUtils jobLauncherTestUtils;
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void whenNumberGeneratorDecider_thenNotifyStepRuns() throws Exception {
|
public void givenNumberGeneratorDecider_whenDeciderRuns_thenStatusIsNotify() throws Exception {
|
||||||
JobExecution jobExecution = jobLauncherTestUtils.launchJob();
|
JobExecution jobExecution = jobLauncherTestUtils.launchJob();
|
||||||
Collection<StepExecution> actualStepExecutions = jobExecution.getStepExecutions();
|
Collection<StepExecution> actualStepExecutions = jobExecution.getStepExecutions();
|
||||||
ExitStatus actualJobExitStatus = jobExecution.getExitStatus();
|
ExitStatus actualJobExitStatus = jobExecution.getExitStatus();
|
||||||
|
|
||||||
assertEquals(actualJobExitStatus.getExitCode().toString(), "COMPLETED");
|
assertEquals("COMPLETED", actualJobExitStatus.getExitCode()
|
||||||
assertEquals(actualStepExecutions.size(), 2);
|
.toString());
|
||||||
|
assertEquals(2, actualStepExecutions.size());
|
||||||
boolean notifyStepDidRun = false;
|
boolean notifyStepDidRun = false;
|
||||||
Iterator<StepExecution> iterator = actualStepExecutions.iterator();
|
Iterator<StepExecution> iterator = actualStepExecutions.iterator();
|
||||||
while (iterator.hasNext() && !notifyStepDidRun) {
|
while (iterator.hasNext() && !notifyStepDidRun) {
|
||||||
if(iterator.next().getStepName().equals("Notify step")){
|
if (iterator.next()
|
||||||
|
.getStepName()
|
||||||
|
.equals("Notify step")) {
|
||||||
notifyStepDidRun = true;
|
notifyStepDidRun = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -12,7 +12,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
|||||||
class NumberInfoUnitTest {
|
class NumberInfoUnitTest {
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void whenPositive_isPositive() {
|
void givenPositive_whenFrom_isPositive() {
|
||||||
assertTrue(NumberInfo.from(1)
|
assertTrue(NumberInfo.from(1)
|
||||||
.isPositive());
|
.isPositive());
|
||||||
assertTrue(NumberInfo.from(11)
|
assertTrue(NumberInfo.from(11)
|
||||||
@ -22,7 +22,7 @@ class NumberInfoUnitTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void whenNegative_isPositive_isFalse() {
|
void givenNegative_whenFrom_isNegative() {
|
||||||
assertFalse(NumberInfo.from(-1)
|
assertFalse(NumberInfo.from(-1)
|
||||||
.isPositive());
|
.isPositive());
|
||||||
assertFalse(NumberInfo.from(-10)
|
assertFalse(NumberInfo.from(-10)
|
||||||
@ -30,7 +30,7 @@ class NumberInfoUnitTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void whenEven_isEven() {
|
void givenEven_whenFrom_isEven() {
|
||||||
assertTrue(NumberInfo.from(0)
|
assertTrue(NumberInfo.from(0)
|
||||||
.isEven());
|
.isEven());
|
||||||
assertTrue(NumberInfo.from(-2)
|
assertTrue(NumberInfo.from(-2)
|
||||||
@ -44,7 +44,7 @@ class NumberInfoUnitTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void whenOdd_isEven_isFalse() {
|
void givenOdd_whenFrom_isOdd() {
|
||||||
|
|
||||||
assertFalse(NumberInfo.from(1)
|
assertFalse(NumberInfo.from(1)
|
||||||
.isEven());
|
.isEven());
|
||||||
@ -62,7 +62,7 @@ class NumberInfoUnitTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void testStatic_fromMethod_equals_getNumber() {
|
void giveGeneratedInt_whenFrom_isNumberFromGenerator() {
|
||||||
for (int i = -100; i < 100; i++) {
|
for (int i = -100; i < 100; i++) {
|
||||||
assertEquals(i, NumberInfo.from(i)
|
assertEquals(i, NumberInfo.from(i)
|
||||||
.getNumber());
|
.getNumber());
|
||||||
|
@ -8,7 +8,7 @@ import org.junit.jupiter.api.Test;
|
|||||||
class NumberInfoClassifierUnitTest {
|
class NumberInfoClassifierUnitTest {
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void process_convertsToInteger() throws Exception {
|
void givenNumberInfo_whenProcess_thenConvertsToInteger() throws Exception {
|
||||||
NumberInfoClassifier nic = new NumberInfoClassifier();
|
NumberInfoClassifier nic = new NumberInfoClassifier();
|
||||||
assertEquals(Integer.valueOf(4), nic.process(NumberInfo.from(4)));
|
assertEquals(Integer.valueOf(4), nic.process(NumberInfo.from(4)));
|
||||||
assertEquals(Integer.valueOf(-4), nic.process(NumberInfo.from(-4)));
|
assertEquals(Integer.valueOf(-4), nic.process(NumberInfo.from(-4)));
|
||||||
|
@ -8,7 +8,7 @@ import org.junit.jupiter.api.Test;
|
|||||||
|
|
||||||
public class NumberInfoGeneratorUnitTest {
|
public class NumberInfoGeneratorUnitTest {
|
||||||
@Test
|
@Test
|
||||||
public void testGenerateNumbers_correctOrderAndValue() {
|
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);
|
NumberInfoGenerator numberGenerator = new NumberInfoGenerator(numbers);
|
||||||
assertEquals(new NumberInfo(numbers[0]), numberGenerator.read());
|
assertEquals(new NumberInfo(numbers[0]), numberGenerator.read());
|
||||||
|
Loading…
x
Reference in New Issue
Block a user