|
18 | 18 |
|
19 | 19 | import javax.sql.DataSource; |
20 | 20 |
|
21 | | -import org.springframework.batch.core.configuration.ListableJobLocator; |
22 | 21 | import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing; |
23 | 22 | import org.springframework.batch.core.configuration.support.DefaultBatchConfiguration; |
24 | | -import org.springframework.batch.core.converter.JobParametersConverter; |
25 | 23 | import org.springframework.batch.core.explore.JobExplorer; |
26 | 24 | import org.springframework.batch.core.launch.JobLauncher; |
27 | | -import org.springframework.batch.core.launch.JobOperator; |
28 | | -import org.springframework.batch.core.launch.support.SimpleJobOperator; |
29 | 25 | import org.springframework.batch.core.repository.JobRepository; |
30 | 26 | import org.springframework.beans.factory.ObjectProvider; |
31 | 27 | import org.springframework.boot.ExitCodeGenerator; |
@@ -92,20 +88,6 @@ public JobExecutionExitCodeGenerator jobExecutionExitCodeGenerator() { |
92 | 88 | return new JobExecutionExitCodeGenerator(); |
93 | 89 | } |
94 | 90 |
|
95 | | - @Bean |
96 | | - @ConditionalOnMissingBean(JobOperator.class) |
97 | | - public SimpleJobOperator jobOperator(ObjectProvider<JobParametersConverter> jobParametersConverter, |
98 | | - JobExplorer jobExplorer, JobLauncher jobLauncher, ListableJobLocator jobRegistry, |
99 | | - JobRepository jobRepository) throws Exception { |
100 | | - SimpleJobOperator factory = new SimpleJobOperator(); |
101 | | - factory.setJobExplorer(jobExplorer); |
102 | | - factory.setJobLauncher(jobLauncher); |
103 | | - factory.setJobRegistry(jobRegistry); |
104 | | - factory.setJobRepository(jobRepository); |
105 | | - jobParametersConverter.ifAvailable(factory::setJobParametersConverter); |
106 | | - return factory; |
107 | | - } |
108 | | - |
109 | 91 | @Configuration(proxyBeanMethods = false) |
110 | 92 | static class SpringBootBatchConfiguration extends DefaultBatchConfiguration { |
111 | 93 |
|
|
0 commit comments