我正在尝试设置监听器将手动向 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.CHANNEL
和 AmqpHeaders.DELIVERY_TAG
.
您需要调用basicAck
在 channel 上,传递交货标签。