@Target(TYPE) @Retention(RUNTIME) @Documented @EnableIntegration @Import(BatchIntegrationConfiguration.class) public @interface EnableBatchIntegration

Enable Spring Batch Integration features and provide a base configuration for setting up remote chunking or partitioning infrastructure beans. By adding this annotation on a Configuration class, it will be possible to autowire the following beans:

RemoteChunkingManagerStepBuilderFactory: used to create a manager step of a remote chunking setup by automatically setting the job repository and transaction manager.
RemoteChunkingWorkerBuilder: used to create the integration flow on the worker side of a remote chunking setup.
RemotePartitioningManagerStepBuilderFactory: used to create a manager step of a remote partitioning setup by automatically setting the job repository, job explorer, bean factory and transaction manager.
RemotePartitioningWorkerStepBuilderFactory: used to create a worker step of a remote partitioning setup by automatically setting the job repository, job explorer, bean factory and transaction manager.

For remote chunking, an example of a configuration class would be:

 @Configuration
 @EnableBatchIntegration
 @EnableBatchProcessing
 public class RemoteChunkingAppConfig {

     @Autowired
     private RemoteChunkingManagerStepBuilderFactory managerStepBuilderFactory;

     @Autowired
     private RemoteChunkingWorkerBuilder workerBuilder;

     @Bean
     public TaskletStep managerStep() {
         return this.managerStepBuilderFactory
                 .get("managerStep")
                 .chunk(100)
                 .reader(itemReader())
                 .outputChannel(outgoingRequestsToWorkers())
                 .inputChannel(incomingRepliesFromWorkers())
                 .build();
     }

     @Bean
     public IntegrationFlow worker() {
         return this.workerBuilder
                 .itemProcessor(itemProcessor())
                 .itemWriter(itemWriter())
                 .inputChannel(incomingRequestsFromManager())
                 .outputChannel(outgoingRepliesToManager())
                 .build();
     }

     // Middleware beans omitted

 }

For remote partitioning, an example of a configuration class would be:

 @Configuration
 @EnableBatchIntegration
 @EnableBatchProcessing
 public class RemotePartitioningAppConfig {

     @Autowired
     private RemotePartitioningManagerStepBuilderFactory managerStepBuilderFactory;

     @Autowired
     private RemotePartitioningWorkerStepBuilderFactory workerStepBuilderFactory;

     @Bean
     public Step managerStep() {
         return this.managerStepBuilderFactory
                 .get("managerStep")
                 .partitioner("workerStep", partitioner())
                 .gridSize(10)
                 .outputChannel(outgoingRequestsToWorkers())
                 .inputChannel(incomingRepliesFromWorkers())
                 .build();
     }

     @Bean
     public Step workerStep() {
         return this.workerStepBuilderFactory
                 .get("workerStep")
                 .inputChannel(incomingRequestsFromManager())
                 .outputChannel(outgoingRepliesToManager())
                 .chunk(100)
                 .reader(itemReader())
                 .processor(itemProcessor())
                 .writer(itemWriter())
                 .build();
     }

     // Middleware beans omitted

 }

Since:: 4.1
Author:: Mahmoud Ben Hassine, Taeik Lim

Annotation Interface EnableBatchIntegration