org.springframework.batch.sample.remotepartitioning.polling

Class WorkerConfiguration

java.lang.Object

org.springframework.batch.sample.remotepartitioning.polling.WorkerConfiguration

@Configuration
 @EnableBatchProcessing
 @EnableIntegration
 @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(StepBuilderFactory stepBuilderFactory, JobExplorer jobExplorer, org.springframework.context.ApplicationContext applicationContext)

Method Summary

Modifier and Type	Method and Description
Tasklet	getTasklet(java.lang.String partition)
org.springframework.integration.dsl.IntegrationFlow	inboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
org.springframework.integration.channel.NullChannel	replies()
org.springframework.integration.channel.DirectChannel	requests()
Step	slaveStep()
StepExecutionRequestHandler	stepExecutionRequestHandler()

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerConfiguration

public WorkerConfiguration(StepBuilderFactory stepBuilderFactory,
                           JobExplorer jobExplorer,
                           org.springframework.context.ApplicationContext applicationContext)

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.NullChannel replies()

stepExecutionRequestHandler

@Bean
 @ServiceActivator(inputChannel="requests",
                  outputChannel="replies")
public StepExecutionRequestHandler stepExecutionRequestHandler()

slaveStep

@Bean
public Step slaveStep()

getTasklet

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