阿耳忒弥斯：如何在错误时停止使用消息？

Question

<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());
}

当发送消息1、消息2错误和消息3时，我希望使用者处理消息1并永远重试消息2错误。消息3在消息2错误成功使用之前不应处理。实际发生的情况是，message3在两次重试之间被消耗。如何改变这种行为？有什么想法吗？

Answer 1

ActiveMQ预取默认为1000。

请参阅文档。

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