Блог

Как упоминалось в документации, облачный поток Spring позволяет выполнять функции с несколькими входными и выходными аргументами, как показано ниже:

https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream.html#_functions_with_multiple_input_and_output_arguments

Мой вопрос: Как я могу отправить только в одно (1) исходящее место назначения в зависимости от некоторых бизнес-условий. (используя функциональный подход)?

     @Bean
public static Function<Flux<CalculateCreditCommand>, Tuple2<Flux<CreditCalculatedEvent>, Flux<CreditCalculationFailedEvent>>> myProcessor() {
    return flux -> {
        //If credit was calulated then CreditCalculatedEvent
        //else CreditCalculationFailedEvent
        return ...
    };
}
 

Примечание: фрагмент просто для того, чтобы объяснить, чего я хочу достичь. Спасибо