Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

IN PROGRESS - issue BATCH-825: Modify JobLauncher contract to not throw exception on job failure.

Browse Source 
http://jira.springframework.org/browse/BATCH-825

AbstractStepTests was still broken, but isn't part of the build.
This commit is contained in:
lucasward
2008-09-17 18:01:50 +00:00
parent 3f3871cbf0
commit 52049493b9
1 changed files with 13 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
spring-batch-core/src/test/java/org/springframework/batch/core/step/AbstractStepTests.java
View File

@@ -5,9 +5,9 @@ import java.util.List;
import junit.framework.TestCase;
import org.springframework.batch.core.BatchStatus;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobInstance;
import org.springframework.batch.core.JobInterruptedException;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.StepExecution;
import org.springframework.batch.core.StepExecutionListener;
@@ -165,13 +165,10 @@ public class AbstractStepTests extends TestCase {
tested.setJobRepository(repository);
tested.setStepExecutionListeners(new StepExecutionListener[] { listener1, listener2 });
try {
tested.execute(execution);
fail();
}
catch (RuntimeException expected) {
assertEquals("crash!", expected.getMessage());
}
tested.execute(execution);
assertEquals(BatchStatus.FAILED, execution.getStatus());
Throwable expected = execution.getFailureExceptions().get(0);
assertEquals("crash!", expected.getMessage());
int i = 0;
assertEquals("listener1#beforeStep", events.get(i++));
@@ -202,13 +199,10 @@ public class AbstractStepTests extends TestCase {
tested.setJobRepository(repository);
tested.setStepExecutionListeners(new StepExecutionListener[] { listener1, listener2 });
try {
tested.execute(execution);
fail();
}
catch (JobInterruptedException expected) {
assertEquals("JobExecution interrupted.", expected.getMessage());
}
tested.execute(execution);
assertEquals(BatchStatus.STOPPED, execution.getStatus());
Throwable expected = execution.getFailureExceptions().get(0);
assertEquals("JobExecution interrupted.", expected.getMessage());
int i = 0;
assertEquals("listener1#beforeStep", events.get(i++));
@@ -243,13 +237,10 @@ public class AbstractStepTests extends TestCase {
};
tested.setJobRepository(repository);
try {
tested.execute(execution);
fail();
}
catch (RuntimeException expected) {
assertEquals("Bad context!", expected.getCause().getMessage());
}
tested.execute(execution);
assertEquals(BatchStatus.UNKNOWN, execution.getStatus());
Throwable expected = execution.getFailureExceptions().get(0);
assertEquals("Bad context!", expected.getMessage());
int i = 0;
assertEquals("open", events.get(i++));