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

类 WorkerConfiguration

  • @Configuration
@EnableBatchProcessing
@EnableBatchIntegration
@EnableIntegration
@PropertySource("classpath:remote-chunking.properties")
public class WorkerConfiguration
extends java.lang.Object
    This configuration class is for the worker side of the remote chunking sample. It uses the RemoteChunkingWorkerBuilder to configure an IntegrationFlow in order to:
    • receive requests from the master
    • process chunks with the configured item processor and writer
    • send replies to the master
    作者:
    Mahmoud Ben Hassine

    • 方法概要

      所有方法 实例方法 具体方法 
      修饰符和类型方法说明
      org.apache.activemq.ActiveMQConnectionFactoryconnectionFactory() 
      org.springframework.integration.dsl.IntegrationFlowinboundFlow​(org.apache.activemq.ActiveMQConnectionFactory connectionFactory) 
      ItemProcessor<java.lang.Integer,​java.lang.Integer>itemProcessor() 
      ItemWriter<java.lang.Integer>itemWriter() 
      org.springframework.integration.dsl.IntegrationFlowoutboundFlow​(org.apache.activemq.ActiveMQConnectionFactory connectionFactory) 
      org.springframework.integration.channel.DirectChannelreplies() 
      org.springframework.integration.channel.DirectChannelrequests() 
      org.springframework.integration.dsl.IntegrationFlowworkerIntegrationFlow() 

      • 从类继承的方法 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()

      • inboundFlow

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

      • replies

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

      • outboundFlow

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

      • workerIntegrationFlow

        @Bean
public org.springframework.integration.dsl.IntegrationFlow workerIntegrationFlow()