opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 10:54:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #5104] Clean property PROPERTY_TIMER_DELAY_MS if not timer message #

Browse Source
This commit is contained in:
Oliver
2022-09-19 10:01:09 +08:00
committed by GitHub
parent 45937936b8
commit 54d6580f68
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/util/HookUtils.java
+3
View File
@@ -155,6 +155,9 @@ public class HookUtils {
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();
}