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;
           }