Skip to main content
 首页 » 编程设计

rabbitmq之使用 Spring Cloud Stream RabbitMQ 手动确认

2024年11月01日38xiaohuochai

我正在尝试设置监听器将手动向 RabbitMQ 发送 ACK 的场景。我的 application.properties 中有这个

spring.cloud.stream.rabbit.bindings.input.consumer.acknowledge-mode=MANUAL 

如何从监听器发送 ack?
我从 Manual Acknowledgement of Messages : Spring Cloud Stream Kafka 看到对于 Kafka,我们创建一个 Acknowledgement 对象并在其中调用 acknowledge()。 RabbitMQ 有没有做同样事情的例子?

请您参考如下方法:

Spring Integration Reference Manual .该消息有两个 header ,AmqpHeaders.CHANNELAmqpHeaders.DELIVERY_TAG .

您需要调用basicAck在 channel 上,传递交货标签。