71 lines
2.4 KiB
Java
71 lines
2.4 KiB
Java
package com.baeldung.subflows.subflowmapping;
|
|
|
|
import java.util.Arrays;
|
|
import java.util.Collection;
|
|
|
|
import org.springframework.context.ConfigurableApplicationContext;
|
|
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.integration.annotation.Gateway;
|
|
import org.springframework.integration.annotation.IntegrationComponentScan;
|
|
import org.springframework.integration.annotation.MessagingGateway;
|
|
import org.springframework.integration.channel.DirectChannel;
|
|
import org.springframework.integration.config.EnableIntegration;
|
|
import org.springframework.integration.dsl.IntegrationFlow;
|
|
|
|
@EnableIntegration
|
|
@IntegrationComponentScan
|
|
public class RouterExample {
|
|
@MessagingGateway
|
|
public interface I {
|
|
|
|
@Gateway(requestChannel = "flow.input")
|
|
void flow(Collection<Integer> is);
|
|
|
|
}
|
|
|
|
@Bean
|
|
DirectChannel multipleof3Channel() {
|
|
return new DirectChannel();
|
|
}
|
|
|
|
@Bean
|
|
DirectChannel remainderIs1Channel() {
|
|
return new DirectChannel();
|
|
}
|
|
|
|
@Bean
|
|
DirectChannel remainderIs2Channel() {
|
|
return new DirectChannel();
|
|
}
|
|
|
|
@Bean
|
|
public IntegrationFlow flow() {
|
|
return f -> f.split()
|
|
.<Integer, Integer> route(p -> p % 3, m -> m.channelMapping(0, "multipleof3Channel")
|
|
.subFlowMapping(1, sf -> sf .channel("remainderIs1Channel"))
|
|
.subFlowMapping(2, sf -> sf.<Integer> handle((p,h)->p)))
|
|
.channel("remainderIs2Channel");
|
|
}
|
|
|
|
public static void main(String[] args) {
|
|
final ConfigurableApplicationContext ctx = new AnnotationConfigApplicationContext(RouterExample.class);
|
|
|
|
DirectChannel multipleof3Channel = ctx.getBean("multipleof3Channel", DirectChannel.class);
|
|
multipleof3Channel.subscribe(x -> System.out.println("multipleof3Channel: " + x));
|
|
|
|
DirectChannel remainderIs1Channel = ctx.getBean("remainderIs1Channel", DirectChannel.class);
|
|
remainderIs1Channel.subscribe(x -> System.out.println("remainderIs1Channel: " + x));
|
|
|
|
DirectChannel remainderIs2Channel = ctx.getBean("remainderIs2Channel", DirectChannel.class);
|
|
remainderIs2Channel.subscribe(x -> System.out.println("remainderIs2Channel: " + x));
|
|
|
|
ctx.getBean(I.class)
|
|
.flow(Arrays.asList(1, 2, 3, 4, 5, 6));
|
|
|
|
ctx.close();
|
|
|
|
}
|
|
|
|
}
|