org.springframework.xd.dirt.plugins.job.batch

Class DistributedJobService

java.lang.Object

org.springframework.batch.admin.service.SimpleJobService

org.springframework.xd.dirt.plugins.job.batch.DistributedJobService

All Implemented Interfaces:

org.springframework.batch.admin.service.JobService, org.springframework.beans.factory.DisposableBean

public class DistributedJobService
extends org.springframework.batch.admin.service.SimpleJobService

SimpleJobService in distributed mode

Author:

Ilayaperumal Gopinathan

Constructor Summary

Constructors

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)

Method Summary

Methods

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)

Methods inherited from class org.springframework.batch.admin.service.SimpleJobService

countJobExecutions, countJobExecutionsForJob, countJobInstances, countJobs, countStepExecutionsForStep, destroy, getJobExecution, getJobExecutionsForJobInstance, getJobInstance, getLastJobParameters, getStepExecution, getStepExecutions, getStepNamesForJob, isLaunchable, listJobExecutions, listJobInstances, listJobs, listStepExecutionsForStep, removeInactiveExecutions, setShutdownTimeout, stopAll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DistributedJobService

public 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)

Method Detail

launch

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

Specified by:

launch in interface org.springframework.batch.admin.service.JobService

Overrides:

launch in class org.springframework.batch.admin.service.SimpleJobService

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

restart

public 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

Specified by:

restart in interface org.springframework.batch.admin.service.JobService

Overrides:

restart in class org.springframework.batch.admin.service.SimpleJobService

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

stop

public org.springframework.batch.core.JobExecution stop(java.lang.Long jobExecutionId)
                                                 throws org.springframework.batch.core.launch.NoSuchJobExecutionException,
                                                        org.springframework.batch.core.launch.JobExecutionNotRunningException

Specified by:

stop in interface org.springframework.batch.admin.service.JobService

Overrides:

stop in class org.springframework.batch.admin.service.SimpleJobService

Throws:

org.springframework.batch.core.launch.NoSuchJobExecutionException

org.springframework.batch.core.launch.JobExecutionNotRunningException

abandon

public org.springframework.batch.core.JobExecution abandon(java.lang.Long jobExecutionId)
                                                    throws org.springframework.batch.core.launch.NoSuchJobExecutionException,
                                                           org.springframework.batch.core.repository.JobExecutionAlreadyRunningException

Specified by:

abandon in interface org.springframework.batch.admin.service.JobService

Overrides:

abandon in class org.springframework.batch.admin.service.SimpleJobService

Throws:

org.springframework.batch.core.launch.NoSuchJobExecutionException

org.springframework.batch.core.repository.JobExecutionAlreadyRunningException

isIncrementable

public boolean isIncrementable(java.lang.String jobName)

Specified by:

isIncrementable in interface org.springframework.batch.admin.service.JobService

Overrides:

isIncrementable in class org.springframework.batch.admin.service.SimpleJobService

listJobExecutionsForJob

public java.util.Collection<org.springframework.batch.core.JobExecution> listJobExecutionsForJob(java.lang.String jobName,
                                                                                        int start,
                                                                                        int count)
                                                                                          throws org.springframework.batch.core.launch.NoSuchJobException

Specified by:

listJobExecutionsForJob in interface org.springframework.batch.admin.service.JobService

Overrides:

listJobExecutionsForJob in class org.springframework.batch.admin.service.SimpleJobService

Throws:

org.springframework.batch.core.launch.NoSuchJobException