Package org.springframework.batch.sample.remotechunking

Class MasterConfiguration

  • @Configuration
@EnableBatchProcessing
@EnableBatchIntegration
@EnableIntegration
@PropertySource("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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and TypeMethodDescription
      org.apache.activemq.ActiveMQConnectionFactoryconnectionFactory() 
      org.springframework.integration.dsl.IntegrationFlowinboundFlow​(org.apache.activemq.ActiveMQConnectionFactory connectionFactory) 
      ListItemReader<java.lang.Integer>itemReader() 
      TaskletStepmasterStep() 
      org.springframework.integration.dsl.IntegrationFlowoutboundFlow​(org.apache.activemq.ActiveMQConnectionFactory connectionFactory) 
      JobremoteChunkingJob() 
      org.springframework.integration.channel.QueueChannelreplies() 
      org.springframework.integration.channel.DirectChannelrequests() 

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

      • remoteChunkingJob

        @Bean
public Job remoteChunkingJob()