[ISSUE #7577] SlaveActingMaster Timer Message retry without escape logic (#7578)

Co-authored-by: ayue <ericyu0421@163.com>
2026-08-30 18:10:44 +08:00 · 2023-11-24 10:47:08 +08:00
parent 5b43387be3
commit e955e4399c
1 changed files with 5 additions and 1 deletions
@@ -1105,7 +1105,11 @@ public class TimerMessageStore {
                }
            }
            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;