0

我有一个使用 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>
4

1 回答 1

0

你是对的，RabbitMQ 前段时间被改变了。API 中没有任何内容可以更改行为。

当然，您可以error-channel在入站适配器上放置一个转换器expression="payload.failedMessage"（

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

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

于 2013-10-07T22:53:56.190 回答