如何解决ActiveMQ 消费者在现有消息的重新传递完成之前不会获取新消息
这是我的再投递政策
RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
redeliveryPolicy.setMaximumRedeliveries(8);
redeliveryPolicy.setinitialRedeliveryDelay(1000);
redeliveryPolicy.setRedeliveryDelay(10000);
redeliveryPolicy.setBackOffMultiplier(2);
redeliveryPolicy.setUseExponentialBackOff(true);
这是我对 SimpleMessageListenerContainer 的基本配置
setPubSubDomain(false);
setSessionTransacted(true);
setSessionAckNowledgeMode(Session.CLIENT_ACKNowLEDGE);
setDestinationName("my-queue");
setConcurrentConsumers(1);
如果消费者在处理消息时遇到问题,则会按照重新传递策略中的规定,将呈指数回退的消息重新传递给消费者。这工作正常,但问题是在现有消息的重新传递完成或现有消息移至 dlq 之前,消费者不会收到任何新消息。
有什么办法可以避免这种情况吗?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。