From 667b8f03317fe0f4f9b2aed32d08950a7957ba10 Mon Sep 17 00:00:00 2001 From: "shutian.lzh" Date: Tue, 24 Apr 2018 11:10:59 +0800 Subject: [PATCH] Support scheduled message --- .../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 838bbf51..4c6568ae 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 36f0656c..23021413 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)); } } -- GitLab