使用rocketmq5.0 开源版本测试环境建一个服务,发送延时队列不生效(立即收到消息)。

解决办法:topic,group手动创建,即不要自动创建topic和group

发送延时队列方法:

org.apache.rocketmq.spring.core.RocketMQTemplate#syncSendDelayTimeSeconds(java.lang.String, java.lang.Object, long)

更多推荐