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

标签 spring-boot spring-integration spring-cloud-stream spring-cloud-function

在我的 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/

相关文章:

java - 在router之后自动添加bridge组件的目的是什么?

java - Spring Kafka、Spring Cloud Stream 和 Avro 兼容性 Unknown magic byte

Spring Cloud Stream 和@Publisher 注解兼容性

java - 在 Spring 集成流程的多次运行中共享对象

java - 在 TCP 网关中发送响应后向 Spring Integration 中的 serviceActivator 发送消息

java - 使用 Kafka 向 Dlq Spring 云流发送消息时出错

java - 使用spring进行http请求的MD5哈希码

java - Spring Boot可执行jar无法访问索引页

java - Interface Annotation 不接受 application.properties 值

java - 将 Spring Security 添加到 Gradle 项目会破坏 Spring Data JPA?