|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.springframework.batch.core.launch.support.SimpleJobLauncher
public class SimpleJobLauncher
Simple implementation of the JobLauncher interface. The Spring Core
TaskExecutor interface is used to launch a Job. This means
that the type of executor set is very important. If a
SyncTaskExecutor is used, then the job will be processed
within the same thread that called the launcher. Care should
be taken to ensure any users of this class understand fully whether or not
the implementation of TaskExecutor used will start tasks synchronously or
asynchronously. The default setting uses a synchronous task executor.
There is only one required dependency of this Launcher, a
JobRepository. The JobRepository is used to obtain a valid
JobExecution. The Repository must be used because the provided Job
could be a restart of an existing JobInstance, and only the
Repository can reliably recreate it.
JobRepository,
TaskExecutor| Field Summary | |
|---|---|
protected static org.apache.commons.logging.Log |
logger
|
| Constructor Summary | |
|---|---|
SimpleJobLauncher()
|
|
| Method Summary | |
|---|---|
void |
afterPropertiesSet()
Ensure the required dependencies of a JobRepository have been
set. |
JobExecution |
run(Job job,
JobParameters jobParameters)
Run the provided job with the given JobParameters. |
void |
setJobRepository(JobRepository jobRepository)
Set the JobRepsitory. |
void |
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Set the TaskExecutor. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected static final org.apache.commons.logging.Log logger
| Constructor Detail |
|---|
public SimpleJobLauncher()
| Method Detail |
|---|
public JobExecution run(Job job,
JobParameters jobParameters)
throws JobExecutionAlreadyRunningException,
JobRestartException,
JobInstanceAlreadyCompleteException
JobParameters. The
JobParameters will be used to determine if this is an execution
of an existing job instance, or if a new one should be created.
run in interface JobLauncherjob - the job to be run.jobParameters - the JobParameters for this particular
execution.
JobRestartException - if the execution would be a re-start, but a
re-start is either not allowed or not needed.
JobInstanceAlreadyCompleteException - if this instance has already
completed successfully
JobExecutionAlreadyRunningException - if the JobInstance identified
by the properties already has an execution running.public void setJobRepository(JobRepository jobRepository)
jobRepository - public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
taskExecutor -
public void afterPropertiesSet()
throws java.lang.Exception
JobRepository have been
set.
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanjava.lang.Exception
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||