Artemis：如何停止消费错误消息？

Question

如何配置 ActiveMQ Artemis 或我的 Spring JMS 客户端在出错时不使用任何其他消息？

我的代理配置如下：

<addresses>
    <address name="SimplePointToPoint">
        <anycast>
            <queue name="SimplePointToPoint"/>
        </anycast>
    </address>
</addresses>
<address-settings>
    <address-setting match="SimplePointToPoint">
        <max-delivery-attempts>-1</max-delivery-attempts>
    </address-setting>
</address-settings>

这是我的消费者的代码：

@JmsListener(destination = "SimplePointToPoint")
public void consumeMessage(Message<String> message) {
    if (message.getPayload().contains("error"))
        throw new RuntimeException();

    log.info("received message: {}", message.getPayload());
}

发送message1、message2 with error 和message3 时，我希望消费者处理message1 并永远重试message2 with error。在成功使用 message2 with error 之前，不应处理 message3。实际发生的是message3 在重试之间被消耗。如何改变这种行为？有什么想法吗？

Answer 1

ActiveMQ 预取默认为 1000。

见the documentation。

您可以在 ActiveMQConnectionFactory 或 ActiveMQConnection 上指定 ActiveMQPrefetchPolicy 的实例。这允许您配置所有单独的预取值；因为每一种不同的服务质量都有不同的价值。例如

持久队列（默认值：1000）

...