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 <[email protected]>
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
[email protected].
