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

OPEN - issue BATCH-303: Replace repeat contexts in core domain with boolean flag that can be checked by executors

Browse Source 
http://jira.springframework.org/browse/BATCH-303
This commit is contained in:
dsyer
2008-01-22 13:52:17 +00:00
parent 552549f897
commit eeddeff59b
2 changed files with 11 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-batch-execution/src/main/java/org/springframework/batch/execution/job/DefaultJobExecutor.java
View File

@@ -91,8 +91,7 @@ public class DefaultJobExecutor implements JobExecutor {
updateStatus(execution, BatchStatus.STARTED);
StepExecutor stepExecutor = stepExecutorFactory
.getExecutor(step);
StepExecution stepExecution = new StepExecution(stepInstance,
execution);
StepExecution stepExecution = execution.createStepExecution(stepInstance);
status = stepExecutor.process(step,
stepExecution);
}

20
spring-batch-samples/src/test/java/org/springframework/batch/sample/GracefulShutdownFunctionalTest.java
View File

@@ -67,16 +67,16 @@ public class GracefulShutdownFunctionalTest extends AbstractBatchLauncherTests {
launcher.stop();
//it takes a little while for it to shut down.
// Thread.sleep(1000);
//
// assertFalse(launcher.isRunning());
// assertFalse(jobThread.isAlive());
//
// if (!errors.isEmpty()) {
// Exception e = (Exception) errors.get(0);
// e.printStackTrace();
// fail("Unexpected Exception: "+e);
// }
Thread.sleep(1000);
assertFalse(launcher.isRunning());
assertFalse(jobThread.isAlive());
if (!errors.isEmpty()) {
Exception e = (Exception) errors.get(0);
e.printStackTrace();
fail("Unexpected Exception: "+e);
}
}
}