You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2021/05/20 08:47:50 UTC
[rocketmq] branch develop updated: docs(example): change delay
start point (#2586)
This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 4e73ba0 docs(example): change delay start point (#2586)
4e73ba0 is described below
commit 4e73ba0ee374d6a5484eb6184bbc8ff3829a7075
Author: Shang Yehua <ni...@icloud.com>
AuthorDate: Thu May 20 16:47:42 2021 +0800
docs(example): change delay start point (#2586)
As the test results showed, the message delay period starts from the bornTimestamp, not from storeTimestamp
Co-authored-by: Yehua Shang <ni...@outlook.com>
---
docs/cn/RocketMQ_Example.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/cn/RocketMQ_Example.md b/docs/cn/RocketMQ_Example.md
index fd36fd1..d924ce1 100644
--- a/docs/cn/RocketMQ_Example.md
+++ b/docs/cn/RocketMQ_Example.md
@@ -446,7 +446,7 @@ public class ScheduledMessageConsumer {
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> messages, ConsumeConcurrentlyContext context) {
for (MessageExt message : messages) {
// Print approximate delay time period
- System.out.println("Receive message[msgId=" + message.getMsgId() + "] " + (System.currentTimeMillis() - message.getStoreTimestamp()) + "ms later");
+ System.out.println("Receive message[msgId=" + message.getMsgId() + "] " + (System.currentTimeMillis() - message.getBornTimestamp()) + "ms later");
}
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}