如何使用 Spring AMQP 控制最大未确认发布

How to control max unconfirmed publishes using Spring AMQP

我正在测试发布者确认在 Spring-AMQP 中的工作方式,试图找到 How to control max unconfirmed publishes using Spring AMQP?

基本上我想在未确认的消息数大于某个限制时暂停发布者。

似乎 rabbitTemplate.getUnconfirmed(age) 给出了未确认消息的列表,但一旦调用方法,它就会将它们从未确认列表中删除。

是;我们目前没有 API,getUnconfirned(age) 旨在等待超过年龄的确认过期。

我们可能应该添加一个重载方法(不带参数),它只获取未确认的相关数据,或者一个方法只 returns 这样的数量。

随意打开一个"improvement" JIRA Issue,我们应该能够在下一个版本中得到一些东西。