微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

ActiveMQ / AmazonMQ中的消息无限请求

如何解决ActiveMQ / AmazonMQ中的消息无限请求

我有使用ActiveMQ / AmazonMQ无限请求的问题。

在为生产者和消费者创建会话期间,我使用ActiveMQSession.INDIVIDUAL_ACKNowLEDGE作为知识模式。当代码命中

TextMessage textMessage = ...
textMessage.ackNowledge(); 

消息正确出队。 如果发生在ack之类的异常之前,

TextMessage textMessage = ... 
throw new RuntimeException();
//textMessage.ackNowledge(); 

邮件重新排队。 在代理配置中,我尝试放入

<redeliveryPlugin fallbackToDeadLetter="true" sendToDlqIfMaxRetriesExceeded="true">
    <redeliveryPolicyMap>
        <redeliveryPolicyMap>
            <defaultEntry>
                <redeliveryPolicy initialRedeliveryDelay="5000" maximumRedeliveries="1"
                                  redeliveryDelay="10000"/>
            </defaultEntry>
        </redeliveryPolicyMap>
    </redeliveryPolicyMap>
</redeliveryPlugin>

并在客户端使用代理URL

?jms.redeliveryPolicy.maximumRedeliveries=0

但是,即使重新传递标志设置为true并且JMSXDeliveryCount大于0,消息也会重新传递。 我想念的是什么?

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。