花影流年

rocketMQ第一波发送的延迟消息消费者不消费

org.apache.rocketmq rocketmq-spring-boot-starter 2.2.3 rocketMQ第一波发送的延迟消息消费者不消费，然而第二波发送的延迟消息能被消费者消费，求大声解答

CO_co

RocketMQ异常重试的时候，为何会触发相同群组的其他不同的Tag监听？

我一个springboot项目里，有2个相同主题相同群组，不同tag的监听。 为了测试异常重试机制，我在监听tagA的那个逻辑里，触发一个异常，希望RocketMQ可以重发异常到这个tagA监听里。 结果神奇的是，日志显示tagA逻辑触发了异常，接下来居然是tagB被触发了，但是我压根没发送过tagB的消息啊。。。。而且tabB的逻辑还一直被触发了多次。 另外，如果tagA的逻辑不触发异常，则tagB的监听不会被触发。RocketMQ也没改过什么，应该不是广播模式。 *** 这是发送的代码 rocketMQTemplate.syncSend(g_mqTopic + ":tagA", "123"); 这个是监听的逻辑 @RocketMQMessageListener(topic = "${my.mqTopic}", selectorExpression = "tagA", consumerGroup = "${my.mqTopic}-consumergroup1") @RocketMQMessageListener(topic = "${my.mqTopic}", selectorExpression = "tagB", consumerGroup = "${my.mqTopic}-consumergroup1")