我有一个使用 Spring 和 RabbitMQ 的项目设置。目前,我的应用程序可能会接收到无法处理的 amqp 消息,直到另一个异步进程完成(遗留和完全分离,我无法控制)。所以结果是我可能不得不等待处理消息一段时间。其结果是变压器中的异常。
当消息被 NACK 返回到 rabbitMQ 时,它会将其放回队列的头部并立即重新拉取它。如果我收到的无法处理的消息等于并发侦听器的数量,我的工作流程就会锁定。它旋转它的轮子等待消息变得可处理,即使队列中有有效的可处理消息在等待。
有没有办法拒绝和 amqp 消息并让它回到队列的尾部?根据我的研究,rabbitMQ 曾经以这种方式工作,但现在我似乎只排在队列的首位。
我的配置相当简单,但为了连续性,它是......
连接工厂是:org.springframework.amqp.rabbit.connection.CachingConnectionFactory RabbitMQ 3.1.1
弹簧集成:2.2.0
<si:channel id="channel"/>
<si-amqp:inbound-channel-adapter
queue-names="commit" channel="channel" connection-factory="amqpConnectionFactory"
acknowledge-mode="AUTO" concurrent-consumers="${listeners}"
channel-transacted="true"
transaction-manager="transactionManager"/>
<si:chain input-channel="channel" output-channel="nullChannel">
<si:transformer ref="transformer"></si:transformer>
<si:service-activator ref="activator"/>
</si:chain>