rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lizhan...@apache.org
Subject [rocketmq] branch develop_oms_0.3.0 updated: Support scheduled message
Date Tue, 24 Apr 2018 03:11:09 GMT
This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch develop_oms_0.3.0
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop_oms_0.3.0 by this push:
     new 667b8f0  Support scheduled message
667b8f0 is described below

commit 667b8f03317fe0f4f9b2aed32d08950a7957ba10
Author: shutian.lzh <shutian.lzh@alibaba-inc.com>
AuthorDate: Tue Apr 24 11:10:59 2018 +0800

    Support scheduled message
---
 .../main/java/io/openmessaging/rocketmq/domain/RocketMQConstants.java   | 2 +-
 .../src/main/java/io/openmessaging/rocketmq/utils/OMSUtil.java          | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/openmessaging/src/main/java/io/openmessaging/rocketmq/domain/RocketMQConstants.java
b/openmessaging/src/main/java/io/openmessaging/rocketmq/domain/RocketMQConstants.java
index 838bbf5..4c6568a 100644
--- a/openmessaging/src/main/java/io/openmessaging/rocketmq/domain/RocketMQConstants.java
+++ b/openmessaging/src/main/java/io/openmessaging/rocketmq/domain/RocketMQConstants.java
@@ -2,6 +2,6 @@ package io.openmessaging.rocketmq.domain;
 
 public interface RocketMQConstants {
 
-    String STARTDELIVERTIME = "__STARTDELIVERTIME";
+    String START_DELIVER_TIME = "__STARTDELIVERTIME";
 
 }
diff --git a/openmessaging/src/main/java/io/openmessaging/rocketmq/utils/OMSUtil.java b/openmessaging/src/main/java/io/openmessaging/rocketmq/utils/OMSUtil.java
index 36f0656..2302141 100644
--- a/openmessaging/src/main/java/io/openmessaging/rocketmq/utils/OMSUtil.java
+++ b/openmessaging/src/main/java/io/openmessaging/rocketmq/utils/OMSUtil.java
@@ -57,7 +57,7 @@ public class OMSUtil {
         if (sysHeaders.containsKey(BuiltinKeys.START_TIME)) {
             long deliverTime = sysHeaders.getLong(BuiltinKeys.START_TIME, 0);
             if (deliverTime > 0) {
-                rmqMessage.putUserProperty(RocketMQConstants.STARTDELIVERTIME, String.valueOf(deliverTime));
+                rmqMessage.putUserProperty(RocketMQConstants.START_DELIVER_TIME, String.valueOf(deliverTime));
             }
         }
 

-- 
To stop receiving notification emails like this one, please contact
lizhanhui@apache.org.

Mime
View raw message