春云流后的后处理函数

Question

可以使用下面的简单函数来生成消息。

@Bean
public Function<String, String> toUpperCase() {
return s -> s.toUpperCase();
}

在spring云流中是否有任何选项可以在发布/提供消息后将控制权返回给应用程序?

我有一个在发布消息后更新数据库状态的用例。

Answer 1

用Consumer代替Function，用StreamBridge代替发送结果

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