public class DistributedJobService
extends org.springframework.batch.admin.service.SimpleJobService
| Constructor and Description |
|---|
DistributedJobService(org.springframework.batch.admin.service.SearchableJobInstanceDao jobInstanceDao,
org.springframework.batch.admin.service.SearchableJobExecutionDao jobExecutionDao,
org.springframework.batch.admin.service.SearchableStepExecutionDao stepExecutionDao,
org.springframework.batch.core.repository.JobRepository jobRepository,
org.springframework.batch.core.launch.JobLauncher jobLauncher,
DistributedJobLocator batchJobLocator,
org.springframework.batch.core.repository.dao.ExecutionContextDao executionContextDao) |
| Modifier and Type | Method and Description |
|---|---|
org.springframework.batch.core.JobExecution |
abandon(java.lang.Long jobExecutionId) |
org.springframework.batch.core.Job |
getJob(java.lang.String jobName) |
boolean |
isIncrementable(java.lang.String jobName) |
org.springframework.batch.core.JobExecution |
launch(java.lang.String jobName,
org.springframework.batch.core.JobParameters params) |
org.springframework.batch.core.JobExecution |
restart(java.lang.Long jobExecutionId) |
countJobExecutions, countJobExecutionsForJob, countJobInstances, countJobs, countStepExecutionsForStep, destroy, getJobExecution, getJobExecutionsForJobInstance, getJobInstance, getLastJobParameters, getStepExecution, getStepExecutions, getStepNamesForJob, isLaunchable, listJobExecutions, listJobExecutionsForJob, listJobInstances, listJobs, listStepExecutionsForStep, removeInactiveExecutions, setShutdownTimeout, stop, stopAllpublic DistributedJobService(org.springframework.batch.admin.service.SearchableJobInstanceDao jobInstanceDao,
org.springframework.batch.admin.service.SearchableJobExecutionDao jobExecutionDao,
org.springframework.batch.admin.service.SearchableStepExecutionDao stepExecutionDao,
org.springframework.batch.core.repository.JobRepository jobRepository,
org.springframework.batch.core.launch.JobLauncher jobLauncher,
DistributedJobLocator batchJobLocator,
org.springframework.batch.core.repository.dao.ExecutionContextDao executionContextDao)
public org.springframework.batch.core.JobExecution launch(java.lang.String jobName,
org.springframework.batch.core.JobParameters params)
throws org.springframework.batch.core.launch.NoSuchJobException,
org.springframework.batch.core.repository.JobExecutionAlreadyRunningException,
org.springframework.batch.core.repository.JobRestartException,
org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException,
org.springframework.batch.core.JobParametersInvalidException
launch in interface org.springframework.batch.admin.service.JobServicelaunch in class org.springframework.batch.admin.service.SimpleJobServiceorg.springframework.batch.core.launch.NoSuchJobExceptionorg.springframework.batch.core.repository.JobExecutionAlreadyRunningExceptionorg.springframework.batch.core.repository.JobRestartExceptionorg.springframework.batch.core.repository.JobInstanceAlreadyCompleteExceptionorg.springframework.batch.core.JobParametersInvalidExceptionpublic org.springframework.batch.core.JobExecution restart(java.lang.Long jobExecutionId)
throws org.springframework.batch.core.launch.NoSuchJobExecutionException,
org.springframework.batch.core.repository.JobExecutionAlreadyRunningException,
org.springframework.batch.core.repository.JobRestartException,
org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException,
org.springframework.batch.core.launch.NoSuchJobException,
org.springframework.batch.core.JobParametersInvalidException
restart in interface org.springframework.batch.admin.service.JobServicerestart in class org.springframework.batch.admin.service.SimpleJobServiceorg.springframework.batch.core.launch.NoSuchJobExecutionExceptionorg.springframework.batch.core.repository.JobExecutionAlreadyRunningExceptionorg.springframework.batch.core.repository.JobRestartExceptionorg.springframework.batch.core.repository.JobInstanceAlreadyCompleteExceptionorg.springframework.batch.core.launch.NoSuchJobExceptionorg.springframework.batch.core.JobParametersInvalidExceptionpublic org.springframework.batch.core.JobExecution abandon(java.lang.Long jobExecutionId)
throws org.springframework.batch.core.launch.NoSuchJobExecutionException,
org.springframework.batch.core.repository.JobExecutionAlreadyRunningException
abandon in interface org.springframework.batch.admin.service.JobServiceabandon in class org.springframework.batch.admin.service.SimpleJobServiceorg.springframework.batch.core.launch.NoSuchJobExecutionExceptionorg.springframework.batch.core.repository.JobExecutionAlreadyRunningExceptionpublic boolean isIncrementable(java.lang.String jobName)
isIncrementable in interface org.springframework.batch.admin.service.JobServiceisIncrementable in class org.springframework.batch.admin.service.SimpleJobServicepublic org.springframework.batch.core.Job getJob(java.lang.String jobName)
throws org.springframework.batch.core.launch.NoSuchJobException
org.springframework.batch.core.launch.NoSuchJobException