Class MasterConfiguration
- java.lang.Object
- org.springframework.batch.sample.remotepartitioning.aggregating.MasterConfiguration
@Configuration @EnableBatchProcessing @EnableBatchIntegration @Import({DataSourceConfiguration.class,BrokerConfiguration.class}) public class MasterConfiguration extends java.lang.Object
This configuration class is for the master side of the remote partitioning sample. The master step will create 3 partitions for workers to process.- Author:
- Mahmoud Ben Hassine
Constructor Summary
Constructors Constructor Description MasterConfiguration(JobBuilderFactory jobBuilderFactory, RemotePartitioningMasterStepBuilderFactory masterStepBuilderFactory)
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.springframework.integration.dsl.IntegrationFlow
inboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
Step
masterStep()
org.springframework.integration.dsl.IntegrationFlow
outboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
Job
remotePartitioningJob()
org.springframework.integration.channel.DirectChannel
replies()
org.springframework.integration.channel.DirectChannel
requests()
Constructor Detail
MasterConfiguration
public MasterConfiguration(JobBuilderFactory jobBuilderFactory, RemotePartitioningMasterStepBuilderFactory masterStepBuilderFactory)
Method Detail
requests
@Bean public org.springframework.integration.channel.DirectChannel requests()
outboundFlow
@Bean public org.springframework.integration.dsl.IntegrationFlow outboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
replies
@Bean public org.springframework.integration.channel.DirectChannel replies()
inboundFlow
@Bean public org.springframework.integration.dsl.IntegrationFlow inboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
masterStep
@Bean public Step masterStep()
remotePartitioningJob
@Bean public Job remotePartitioningJob()