org.springframework.batch.sample.remotepartitioning.aggregating

Class WorkerConfiguration

java.lang.Object

org.springframework.batch.sample.remotepartitioning.aggregating.WorkerConfiguration

@Configuration
 @EnableBatchProcessing
 @EnableBatchIntegration
 @Import(value={DataSourceConfiguration.class,BrokerConfiguration.class})
public class WorkerConfiguration
extends java.lang.Object

This configuration class is for the worker side of the remote partitioning sample. Each worker will process a partition sent by the master step.

Author:

Mahmoud Ben Hassine

Constructor Summary

Constructors

Constructor and Description
WorkerConfiguration(RemotePartitioningWorkerStepBuilderFactory workerStepBuilderFactory)

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.dsl.IntegrationFlow	inboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
org.springframework.integration.dsl.IntegrationFlow	outboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
org.springframework.integration.channel.DirectChannel	replies()
org.springframework.integration.channel.DirectChannel	requests()
Tasklet	tasklet(java.lang.String partition)
Step	workerStep()

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerConfiguration

public WorkerConfiguration(RemotePartitioningWorkerStepBuilderFactory workerStepBuilderFactory)

Method Detail

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)

workerStep

@Bean
public Step workerStep()

tasklet

@Bean
 @StepScope
public Tasklet tasklet(@Value(value="#{stepExecutionContext[\'partition\']}")
                                         java.lang.String partition)