org.springframework.batch.sample.remotechunking

Class WorkerConfiguration

java.lang.Object

org.springframework.batch.sample.remotechunking.WorkerConfiguration

@Configuration
 @EnableBatchProcessing
 @EnableIntegration
 @PropertySource(value="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 configures a ChunkProcessorChunkHandler as a service activator to:

• receive requests from the master
• process chunks with the configured item processor and writer
• send replies to the master

Author:

Mahmoud Ben Hassine

Constructor Summary

Constructors

Constructor and Description
WorkerConfiguration()

Method Summary

Modifier and Type	Method and Description
ChunkProcessorChunkHandler<java.lang.Integer>	chunkProcessorChunkHandler()
org.apache.activemq.ActiveMQConnectionFactory	connectionFactory()
org.springframework.integration.dsl.IntegrationFlow	inboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
ItemProcessor<java.lang.Integer,java.lang.Integer>	itemProcessor()
ItemWriter<java.lang.Integer>	itemWriter()
org.springframework.integration.dsl.IntegrationFlow	outboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
org.springframework.integration.channel.DirectChannel	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

WorkerConfiguration

public WorkerConfiguration()

Method Detail

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)

itemProcessor

@Bean
public ItemProcessor<java.lang.Integer,java.lang.Integer> itemProcessor()

itemWriter

@Bean
public ItemWriter<java.lang.Integer> itemWriter()

chunkProcessorChunkHandler

@Bean
 @ServiceActivator(inputChannel="requests",
                  outputChannel="replies")
public ChunkProcessorChunkHandler<java.lang.Integer> chunkProcessorChunkHandler()