|
|
@ -40,7 +40,6 @@ import org.springframework.batch.core.converter.DefaultJobParametersConverter;
|
|
|
|
import org.springframework.batch.core.converter.JobParametersConverter;
|
|
|
|
import org.springframework.batch.core.converter.JobParametersConverter;
|
|
|
|
import org.springframework.batch.core.explore.JobExplorer;
|
|
|
|
import org.springframework.batch.core.explore.JobExplorer;
|
|
|
|
import org.springframework.batch.core.launch.JobLauncher;
|
|
|
|
import org.springframework.batch.core.launch.JobLauncher;
|
|
|
|
import org.springframework.batch.core.launch.JobParametersNotFoundException;
|
|
|
|
|
|
|
|
import org.springframework.batch.core.launch.NoSuchJobException;
|
|
|
|
import org.springframework.batch.core.launch.NoSuchJobException;
|
|
|
|
import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
|
|
|
|
import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
|
|
|
|
import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;
|
|
|
|
import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;
|
|
|
@ -192,9 +191,8 @@ public class JobLauncherApplicationRunner implements ApplicationRunner, Ordered,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
protected void execute(Job job, JobParameters jobParameters)
|
|
|
|
protected void execute(Job job, JobParameters jobParameters) throws JobExecutionAlreadyRunningException,
|
|
|
|
throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException,
|
|
|
|
JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException {
|
|
|
|
JobParametersInvalidException, JobParametersNotFoundException {
|
|
|
|
|
|
|
|
JobParameters parameters = getNextJobParameters(job, jobParameters);
|
|
|
|
JobParameters parameters = getNextJobParameters(job, jobParameters);
|
|
|
|
JobExecution execution = this.jobLauncher.run(job, parameters);
|
|
|
|
JobExecution execution = this.jobLauncher.run(job, parameters);
|
|
|
|
if (this.publisher != null) {
|
|
|
|
if (this.publisher != null) {
|
|
|
|