[ISSUE apache#7577] SlaveActingMaster Timer Message retry without esc…

…ape logic (apache#7578) Co-authored-by: ayue <[email protected]>
lizhimins · Nov 27, 2023 · d98bb3f · d98bb3f
1 parent 6f56170
commit d98bb3f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
@@ -1105,7 +1105,11 @@ public int doPut(MessageExtBrokerInner message, boolean roll) throws Exception {
                 }
             }
             Thread.sleep(50);
-            putMessageResult = messageStore.putMessage(message);
+            if (escapeBridgeHook != null) {
+                putMessageResult = escapeBridgeHook.apply(message);
+            } else {
+                putMessageResult = messageStore.putMessage(message);
+            }
             LOGGER.warn("Retrying to do put timer msg retryNum:{} putRes:{} msg:{}", retryNum, putMessageResult, message);
         }
         return PUT_NO_RETRY;