问题描述
这是我的再投递政策
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 (将#修改为@)