@Configuration @EnableBatchProcessing @EnableIntegration @Import(value={DataSourceConfiguration.class,BrokerConfiguration.class}) public class MasterConfiguration extends java.lang.Object
Constructor and Description |
---|
MasterConfiguration(JobBuilderFactory jobBuilderFactory,
StepBuilderFactory stepBuilderFactory) |
Modifier and Type | Method and Description |
---|---|
Step |
masterStep() |
org.springframework.integration.dsl.IntegrationFlow |
outboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory) |
Partitioner |
partitioner() |
PartitionHandler |
partitionHandler(javax.sql.DataSource dataSource) |
Job |
remotePartitioningJob() |
org.springframework.integration.channel.DirectChannel |
requests() |
public MasterConfiguration(JobBuilderFactory jobBuilderFactory, StepBuilderFactory stepBuilderFactory)
@Bean public org.springframework.integration.channel.DirectChannel requests()
@Bean public org.springframework.integration.dsl.IntegrationFlow outboundFlow(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
@Bean public Step masterStep()
@Bean public Partitioner partitioner()
@Bean public PartitionHandler partitionHandler(javax.sql.DataSource dataSource)
@Bean public Job remotePartitioningJob()