Я пытаюсь создать ПРОЦЕССОР, который принимает на вход один параметр, и я хочу, чтобы он выдавал несколько выходов, в данном случае два.Я определил это так с интерфейсом costum
public interface MyProcessor {
String INPUT = "myInput";
@Input
SubscribableChannel myInput();
@Output("myOutput")
MessageChannel anOutput();
@Output
MessageChannel anotherOutput();
}
, и чем логика приложения, как это, просто вернуть входной параметр
@SpringBootApplication
@EnableBinding(MyProcessor.class)
public class SpringDataFlowAppApplication {
Logger logger = LoggerFactory.getLogger(SpringDataFlowAppApplication.class);
@Autowired
private MyProcessor processor;
public static void main(String[] args) {
SpringApplication.run(SpringDataFlowAppApplication.class, args);
}
@StreamListener(MyProcessor.INPUT)
public void routeValues(String val) {
processor.anOutput().send(MessageBuilder.withPayload(val).build());
processor.anotherOutput().send(MessageBuilder.withPayload(val).build());
logger.debug("SpringDataFlowAppApplication --> "+val);
}
}
Теперь вопрос в том, как соединить двадругие процессоры в этих выходах, как на рисунке.Я хочу распараллелить некоторые процессы (PROC_! И PROC_2).Для развертывания я использую консоль SpringCloudDataFlow, как показано на рисунке ниже