在我的 spring boot rest Controller 中,我正在使用 StreamBridge 向 rabbitMQ 服务器发送消息,例如
streamBridge.send("consumer-in-0", "hello world");
有没有办法执行发送并等待响应
?
最佳答案
好吧,正如我所说,晚会迟到了,但似乎有办法。只需让生产者同步即可,这可以在 application.properties 中完成:
spring.cloud.stream.kafka.bindings.functionName-out-0.producer.sync=true
相同的配置最初适用于 MessageChannel pre Spring 云功能,但据我了解,底层功能已经相同
关于spring-boot - Spring Cloud Stream - 发送和接收同步,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/64680810/