程序包 org.springframework.batch.sample.remotechunking

类 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.
    作者:
    Mahmoud Ben Hassine

    • 方法概要

      所有方法 实例方法 具体方法 
      修饰符和类型方法说明
      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() 

      • 从类继承的方法 java.lang.Object

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

    • 方法详细资料

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