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

Internal API change for StepExecutors

Browse Source
This commit is contained in:
dsyer
2007-11-05 17:17:33 +00:00
parent 875d1383b4
commit c7b8d038e7
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
execution/src/main/java/org/springframework/batch/execution/step/simple/DefaultStepExecutor.java
View File

@@ -16,6 +16,7 @@
package org.springframework.batch.execution.step.simple;
import org.springframework.batch.core.domain.StepExecution;
import org.springframework.batch.core.domain.StepInstance;
import org.springframework.batch.core.tasklet.Tasklet;
import org.springframework.batch.core.tasklet.Recoverable;
@@ -51,7 +52,7 @@ public class DefaultStepExecutor extends SimpleStepExecutor {
* @see org.springframework.batch.execution.step.simple.SimpleStepExecutor#doTaskletProcessing(org.springframework.batch.core.tasklet.Tasklet,
* org.springframework.batch.core.domain.StepInstance)
*/
protected ExitStatus doTaskletProcessing(Tasklet module, final StepInstance step) throws Exception {
protected ExitStatus doTaskletProcessing(Tasklet module, final StepExecution step) throws Exception {
ExitStatus exitStatus = ExitStatus.CONTINUABLE;

6
execution/src/main/java/org/springframework/batch/execution/step/simple/SimpleStepExecutor.java
View File

@@ -336,7 +336,7 @@ public class SimpleStepExecutor implements StepExecutor {
// check for interruption before each item as well
interruptionPolicy.checkInterrupted(context);
ExitStatus exitStatus = doTaskletProcessing(configuration
.getTasklet(), stepExecution.getStep());
.getTasklet(), stepExecution);
stepExecution.incrementTaskCount();
// check for interruption after each item as well
interruptionPolicy.checkInterrupted(context);
@@ -352,13 +352,13 @@ public class SimpleStepExecutor implements StepExecutor {
*
* @param tasklet
* the unit of business logic to execute
* @param step
* @param stepExecution
* the current step
* @return boolean if there is more processing to do
* @throws Exception
* if there is an error
*/
protected ExitStatus doTaskletProcessing(Tasklet tasklet, StepInstance step)
protected ExitStatus doTaskletProcessing(Tasklet tasklet, StepExecution stepExecution)
throws Exception {
return tasklet.execute();
}