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,
BatchJobLocator 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) |
boolean |
isIncrementable(java.lang.String jobName) |
org.springframework.batch.core.JobExecution |
launch(java.lang.String jobName,
org.springframework.batch.core.JobParameters params) |
java.util.Collection<org.springframework.batch.core.JobExecution> |
listJobExecutionsForJob(java.lang.String jobName,
int start,
int count) |
org.springframework.batch.core.JobExecution |
restart(java.lang.Long jobExecutionId) |
org.springframework.batch.core.JobExecution |
stop(java.lang.Long jobExecutionId) |
countJobExecutions, countJobExecutionsForJob, countJobInstances, countJobs, countStepExecutionsForStep, destroy, getJobExecution, getJobExecutionsForJobInstance, getJobInstance, getLastJobParameters, getStepExecution, getStepExecutions, getStepNamesForJob, isLaunchable, listJobExecutions, listJobInstances, listJobs, listStepExecutionsForStep, removeInactiveExecutions, setShutdownTimeout, 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,
BatchJobLocator 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 stop(java.lang.Long jobExecutionId)
throws org.springframework.batch.core.launch.NoSuchJobExecutionException,
org.springframework.batch.core.launch.JobExecutionNotRunningException
stop in interface org.springframework.batch.admin.service.JobServicestop in class org.springframework.batch.admin.service.SimpleJobServiceorg.springframework.batch.core.launch.NoSuchJobExecutionExceptionorg.springframework.batch.core.launch.JobExecutionNotRunningExceptionpublic 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 java.util.Collection<org.springframework.batch.core.JobExecution> listJobExecutionsForJob(java.lang.String jobName,
int start,
int count)
throws org.springframework.batch.core.launch.NoSuchJobException
listJobExecutionsForJob in interface org.springframework.batch.admin.service.JobServicelistJobExecutionsForJob in class org.springframework.batch.admin.service.SimpleJobServiceorg.springframework.batch.core.launch.NoSuchJobException