|
22 | 22 |
|
23 | 23 | import org.springframework.batch.core.configuration.support.AutomaticJobRegistrar; |
24 | 24 | import org.springframework.batch.core.configuration.support.DefaultJobLoader; |
25 | | -import org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor; |
26 | 25 | import org.springframework.batch.core.configuration.support.MapJobRegistry; |
27 | 26 | import org.springframework.batch.core.explore.support.JobExplorerFactoryBean; |
28 | 27 | import org.springframework.batch.core.launch.support.JobOperatorFactoryBean; |
@@ -62,7 +61,6 @@ public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, B |
62 | 61 | registerJobExplorer(registry, batchAnnotation, importingClassName); |
63 | 62 | registerJobLauncher(registry, batchAnnotation, importingClassName); |
64 | 63 | registerJobRegistry(registry); |
65 | | - registerJobRegistryBeanPostProcessor(registry); |
66 | 64 | registerJobOperator(registry, batchAnnotation); |
67 | 65 | registerAutomaticJobRegistrar(registry, batchAnnotation); |
68 | 66 | watch.stop(); |
@@ -212,19 +210,6 @@ private void registerJobRegistry(BeanDefinitionRegistry registry) { |
212 | 210 | registry.registerBeanDefinition("jobRegistry", beanDefinition); |
213 | 211 | } |
214 | 212 |
|
215 | | - private void registerJobRegistryBeanPostProcessor(BeanDefinitionRegistry registry) { |
216 | | - if (registry.containsBeanDefinition("jobRegistryBeanPostProcessor")) { |
217 | | - LOGGER.info("Bean jobRegistryBeanPostProcessor already defined in the application context, skipping" |
218 | | - + " the registration of a jobRegistryBeanPostProcessor"); |
219 | | - return; |
220 | | - } |
221 | | - BeanDefinitionBuilder beanDefinitionBuilder = BeanDefinitionBuilder |
222 | | - .genericBeanDefinition(JobRegistryBeanPostProcessor.class); |
223 | | - beanDefinitionBuilder.addPropertyReference("jobRegistry", "jobRegistry"); |
224 | | - |
225 | | - registry.registerBeanDefinition("jobRegistryBeanPostProcessor", beanDefinitionBuilder.getBeanDefinition()); |
226 | | - } |
227 | | - |
228 | 213 | private void registerJobOperator(BeanDefinitionRegistry registry, EnableBatchProcessing batchAnnotation) { |
229 | 214 | if (registry.containsBeanDefinition("jobOperator")) { |
230 | 215 | LOGGER.info("Bean jobOperator already defined in the application context, skipping" |
|
0 commit comments