18
18
import org .springframework .batch .core .repository .JobRepository ;
19
19
import org .springframework .batch .integration .chunk .RemoteChunkingMasterStepBuilderFactory ;
20
20
import org .springframework .batch .integration .chunk .RemoteChunkingWorkerBuilder ;
21
+ import org .springframework .beans .BeansException ;
21
22
import org .springframework .beans .factory .annotation .Autowired ;
22
23
import org .springframework .beans .factory .support .BeanDefinitionRegistry ;
24
+ import org .springframework .context .ApplicationContext ;
25
+ import org .springframework .context .ApplicationContextAware ;
23
26
import org .springframework .context .annotation .Bean ;
24
27
import org .springframework .context .annotation .Configuration ;
25
28
import org .springframework .transaction .PlatformTransactionManager ;
31
34
* @author Mahmoud Ben Hassine
32
35
*/
33
36
@ Configuration
34
- public class BatchIntegrationConfiguration {
37
+ public class BatchIntegrationConfiguration implements ApplicationContextAware {
35
38
36
39
private JobRepository jobRepository ;
37
40
@@ -42,11 +45,9 @@ public class BatchIntegrationConfiguration {
42
45
@ Autowired
43
46
public BatchIntegrationConfiguration (
44
47
JobRepository jobRepository ,
45
- PlatformTransactionManager transactionManager ,
46
- BeanDefinitionRegistry beanDefinitionRegistry ) {
48
+ PlatformTransactionManager transactionManager ) {
47
49
this .jobRepository = jobRepository ;
48
50
this .transactionManager = transactionManager ;
49
- this .beanDefinitionRegistry = beanDefinitionRegistry ;
50
51
}
51
52
52
53
@ Bean
@@ -59,4 +60,9 @@ public <I,O> RemoteChunkingWorkerBuilder<I, O> remoteChunkingWorkerBuilder() {
59
60
return new RemoteChunkingWorkerBuilder <>();
60
61
}
61
62
63
+ @ Override
64
+ public void setApplicationContext (ApplicationContext applicationContext ) throws BeansException {
65
+ this .beanDefinitionRegistry = (BeanDefinitionRegistry ) applicationContext ;
66
+ }
67
+
62
68
}
0 commit comments