john1337 opened a new issue, #5646:
URL: https://github.com/apache/rocketmq/issues/5646
example目录下的TimerMessageProducer.java没有起到任何延迟效果,
Message message = new Message(TOPIC, ("Hello scheduled message "
+ i).getBytes(StandardCharsets.UTF_8));
// This message will be delivered to consumer 10 seconds later.
//message.setDelayTimeSec(System.currentTimeMillis()/1000+10);
// The effect is the same as the above
// message.setDelayTimeMs(10_000L);
// Set the specific delivery time, and the effect is the same as
the above
message.setDeliverTimeMs(System.currentTimeMillis() + 60_000L);
感觉rocketmq的示例文档质量欠缺啊,给的示例代码也不能工作,需要加强啊
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]