spring-boot - Spring Cloud Stream - 发送和接收同步

Question

在我的 spring boot rest Controller 中，我正在使用 StreamBridge 向 rabbitMQ 服务器发送消息，例如

streamBridge.send("consumer-in-0", "hello world");

有没有办法执行发送并等待响应？

Answer 1

好吧，正如我所说，晚会迟到了，但似乎有办法。只需让生产者同步即可，这可以在 application.properties 中完成:

spring.cloud.stream.kafka.bindings.functionName-out-0.producer.sync=true

相同的配置最初适用于 MessageChannel pre Spring 云功能，但据我了解，底层功能已经相同