Support scheduled message

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

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