我试图弄清楚在使用 Spring Cloud Stream 应用程序构建生产者时是否有办法配置 PublishConfirm 行为。据我了解,构建生产者有两种方法——Supplier 和 StreamBridge。那么在上述两种机制中是否有任何配置或 api 调用来通过 SCSt 更改 PublishConfirm 配置。
我查看了 SpringCloudStream 文档,但这些示例主要与 amqp 实现相关,而不是 SCSt。
发布确认实际上只是 RabbitMQ 的一个功能:https://rabbitmq-website.pages.dev/tutorials/tutorial-seven-java。因此,它只能在具有 RabbitMQ Binder 的生产者上启用也就不足为奇了。有各自的自动配置属性来启用此功能:
spring.rabbitmq.publisher-confirm-type=correlated
请参阅 Spring AMQP 文档中的更多信息:https://docs.spring.io/spring-amqp/reference/amqp/connections.html#cf-pub-conf-ret