org.springframework.batch.sample.remotepartitioning.aggregating

Class MasterConfiguration

java.lang.Object

org.springframework.batch.sample.remotepartitioning.aggregating.MasterConfiguration

@Configuration
 @EnableBatchProcessing
 @EnableIntegration
 @Import(value={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 and Description
MasterConfiguration(JobBuilderFactory jobBuilderFactory, StepBuilderFactory stepBuilderFactory)

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.channel.DirectChannel	inboundStaging()
org.springframework.integration.dsl.IntegrationFlow	inboundStagingFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
Step	masterStep()
org.springframework.integration.dsl.IntegrationFlow	outboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
Partitioner	partitioner()
PartitionHandler	partitionHandler()
org.springframework.integration.config.AggregatorFactoryBean	partitioningMessageHandler()
Job	remotePartitioningJob()
org.springframework.integration.channel.QueueChannel	replies()
org.springframework.integration.channel.DirectChannel	requests()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MasterConfiguration

public MasterConfiguration(JobBuilderFactory jobBuilderFactory,
                           StepBuilderFactory stepBuilderFactory)

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.QueueChannel replies()

inboundStaging

@Bean
public org.springframework.integration.channel.DirectChannel inboundStaging()

inboundStagingFlow

@Bean
public org.springframework.integration.dsl.IntegrationFlow inboundStagingFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)

masterStep

@Bean
public Step masterStep()

partitioner

@Bean
public Partitioner partitioner()

partitionHandler

@Bean
public PartitionHandler partitionHandler()

partitioningMessageHandler

@Bean
 @ServiceActivator(inputChannel="inboundStaging")
public org.springframework.integration.config.AggregatorFactoryBean partitioningMessageHandler()

remotePartitioningJob

@Bean
public Job remotePartitioningJob()