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 838bbf5176a4c6fd41ff43b020bbf296fef8eacf..4c6568ae0f9c5e5029d4d67107d58d00d29f7e15 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 36f0656caadb99ae19f187f69f5d9dea9c1c79fb..23021413c8079c39a4d2ab419a60274244e1e45d 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)); } }