ActiveMQ 消费者在现有消息的重新传递完成之前不会获取新消息

编程问答 2022-04-29

问题描述

这是我的再投递政策

    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 (将#修改为@）

javajavaspringspring-messaging