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

Internal changes only

Browse Source
This commit is contained in:
dsyer
2007-08-21 17:08:13 +00:00
parent 53257f88ae
commit 8174882e80
2 changed files with 11 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
execution/src/main/java/org/springframework/batch/execution/bootstrap/AbstractJobLauncher.java
View File

@@ -44,7 +44,7 @@ import org.springframework.util.Assert;
* concurrent processing of jobs.
*
* @see JobLauncher
* @author Lucas Ward
* @author Dave Syer
*/
public abstract class AbstractJobLauncher implements JobLauncher,
InitializingBean, ApplicationListener {
@@ -147,15 +147,11 @@ public abstract class AbstractJobLauncher implements JobLauncher,
* the {@link JobIdentifier} to start the launcher with.
* @throws NoSuchJobConfigurationException
*/
protected abstract void doRun(JobIdentifier jobIdentifier)
protected abstract ExitStatus doRun(JobIdentifier jobIdentifier)
throws NoSuchJobConfigurationException;
/**
* Start the provided container. The current thread will first be saved.
* This may seem odd at first, however, this simple bootstrap requires that
* only one thread can kick off a container, and that the first thread that
* calls start is the 'processing thread'. If the container has already been
* started, no exception will be thrown.
* Start the provided {@link JobIdentifier}.
*
* @throws NoSuchJobConfigurationException
* if the container cannot locate a job configuration
@@ -173,16 +169,14 @@ public abstract class AbstractJobLauncher implements JobLauncher,
}
register(jobIdentifier);
doRun(jobIdentifier);
return doRun(jobIdentifier);
/*
* Subclasses have to take care of unregistering the runtimeInformation -
* if we do it here and doStart() is implemented to return immediately
* Subclasses have to take care of unregistering the jobIdentifier -
* if we do it here and doRun() is implemented to return immediately
* without waiting for the job to finish, then we will have a job
* running that is not in the registry.
*/
return ExitStatus.RUNNING;
}
/**

6
execution/src/main/java/org/springframework/batch/execution/bootstrap/TaskExecutorJobLauncher.java
View File

@@ -27,6 +27,7 @@ import org.springframework.batch.core.runtime.JobExecutionContext;
import org.springframework.batch.core.runtime.JobIdentifier;
import org.springframework.batch.execution.JobExecutorFacade;
import org.springframework.batch.execution.NoSuchJobExecutionException;
import org.springframework.batch.repeat.ExitStatus;
import org.springframework.batch.repeat.interceptor.RepeatOperationsApplicationEvent;
import org.springframework.batch.statistics.StatisticsProvider;
import org.springframework.context.ApplicationEvent;
@@ -96,7 +97,7 @@ public class TaskExecutorJobLauncher extends AbstractJobLauncher implements Appl
*
* @throws IllegalStateException if JobConfiguration is null.
*/
protected void doRun(final JobIdentifier runtimeInformation) {
protected ExitStatus doRun(final JobIdentifier runtimeInformation) {
Assert.state(taskExecutor != null, "TaskExecutor must be provided");
@@ -116,6 +117,9 @@ public class TaskExecutorJobLauncher extends AbstractJobLauncher implements Appl
}
}
});
return ExitStatus.RUNNING;
}
/**