Class WorkerConfiguration
- java.lang.Object
- org.springframework.batch.sample.remotepartitioning.polling.WorkerConfiguration
@Configuration @EnableBatchProcessing @EnableBatchIntegration @Import({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 Description WorkerConfiguration(RemotePartitioningWorkerStepBuilderFactory workerStepBuilderFactory)
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.springframework.integration.dsl.IntegrationFlowinboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)org.springframework.integration.channel.DirectChannelrequests()Tasklettasklet(java.lang.String partition)StepworkerStep()
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)
workerStep
@Bean public Step workerStep()
tasklet
@Bean @StepScope public Tasklet tasklet(@Value("#{stepExecutionContext[\'partition\']}") java.lang.String partition)