org.springframework.batch.sample.remotechunking

Class MasterConfiguration

java.lang.Object

org.springframework.batch.sample.remotechunking.MasterConfiguration

@Configuration
 @EnableBatchProcessing
 @EnableBatchIntegration
 @EnableIntegration
 @PropertySource(value="classpath:remote-chunking.properties")
public class MasterConfiguration
extends java.lang.Object

This configuration class is for the master side of the remote chunking sample. The master step reads numbers from 1 to 6 and sends 2 chunks {1, 2, 3} and {4, 5, 6} to workers for processing and writing.

Author:

Mahmoud Ben Hassine

Constructor Summary

Constructors

Constructor and Description
MasterConfiguration()

Method Summary

Modifier and Type	Method and Description
org.apache.activemq.ActiveMQConnectionFactory	connectionFactory()
org.springframework.integration.dsl.IntegrationFlow	inboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
ListItemReader<java.lang.Integer>	itemReader()
TaskletStep	masterStep()
org.springframework.integration.dsl.IntegrationFlow	outboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
Job	remoteChunkingJob()
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()

Method Detail

connectionFactory

@Bean
public org.apache.activemq.ActiveMQConnectionFactory connectionFactory()

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()

inboundFlow

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

itemReader

@Bean
public ListItemReader<java.lang.Integer> itemReader()

masterStep

@Bean
public TaskletStep masterStep()

remoteChunkingJob

@Bean
public Job remoteChunkingJob()