在队列末尾重新排队Amqp消息

Question

我有一个使用Spring和RabbitMQ的项目设置。目前，我的应用程序可能会收到一条amqp消息，在另一个异步进程完成之前无法处理该消息（遗留和完全分离，我无法控制）。因此，结果是我可能不得不等待处理消息一段时间。其结果是变压器出现异常。

当消息被NACK回rabbitMQ时，它会将其放回队列的头部，并立即重新拉入队列。如果我收到的无法处理的消息等于并发侦听器的数量，我的工作流就会被锁定。它转动轮子，等待消息变得可处理，即使队列中有有效的可处理消息在后面等待。

有没有办法拒绝和amqp消息，让它回到队列的尾部？从我的研究RabbitMQ曾经这样工作过，但现在我似乎只得到队列的头。

我的配置相当直接，但为了连续性，这里是...

连接工厂是：org.springframework.amqp.rabbit.connection.CachingConnectionFactory RabbitMQ 3.1.1

Spring集成：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>

Answer 1

你说的没错RabbitMQ在一段时间前被更改了。API中没有任何内容可以更改行为。

当然，您可以在入站适配器上放置一个错误通道，然后是一个变压器（表达式="payload.failedMessage"），然后是一个出站适配器，该适配器配置有适当的交换/路由键来请求队列后面的消息。

您可能想要在错误流中添加一些额外的逻辑来检查异常类型（payload.cause）并决定您想要的操作。

如果错误流本身抛出异常，原始消息将像以前一样在头部重新排队；如果它正常退出，消息将被确认。