Spring Cloud Data Flow с несколькими входами и выходами - PullRequest
0 голосов
/ 05 июля 2019

Я пытаюсь создать ПРОЦЕССОР, который принимает на вход один параметр, и я хочу, чтобы он выдавал несколько выходов, в данном случае два.Я определил это так с интерфейсом 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, как показано на рисунке ниже enter image description here

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...