[ISSUE apache#5104] Clean property PROPERTY_TIMER_DELAY_MS if not tim…

…er message #
mxsm · Sep 19, 2022 · a174e0b · a174e0b
1 parent 2aa8124
commit a174e0b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/util/HookUtils.java b/broker/src/main/java/org/apache/rocketmq/broker/util/HookUtils.java
@@ -155,6 +155,9 @@ public static boolean checkIfTimerMessage(MessageExtBrokerInner msg) {
             if (null != msg.getProperty(MessageConst.PROPERTY_TIMER_DELAY_SEC)) {
                 MessageAccessor.clearProperty(msg, MessageConst.PROPERTY_TIMER_DELAY_SEC);
             }
+            if (null != msg.getProperty(MessageConst.PROPERTY_TIMER_DELAY_MS)) {
+                MessageAccessor.clearProperty(msg, MessageConst.PROPERTY_TIMER_DELAY_MS);
+            }
             return false;
             //return this.defaultMessageStore.getMessageStoreConfig().isTimerInterceptDelayLevel();
         }