This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push: new 920dc32d27 [ISSUE #7760] make timerSkipUnknownError can be set by config file 920dc32d27 is described below commit 920dc32d27032716ec5d6ea6361af5778a9ed7b1 Author: Lei Zhiyuan <leizhiy...@gmail.com> AuthorDate: Fri Jan 19 09:59:23 2024 +0800 [ISSUE #7760] make timerSkipUnknownError can be set by config file --- .../java/org/apache/rocketmq/store/config/MessageStoreConfig.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java b/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java index 8cb3ea6e9e..192214ada7 100644 --- a/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java +++ b/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java @@ -1609,6 +1609,10 @@ public class MessageStoreConfig { return timerSkipUnknownError; } + public void setTimerSkipUnknownError(boolean timerSkipUnknownError) { + this.timerSkipUnknownError = timerSkipUnknownError; + } + public boolean isTimerWarmEnable() { return timerWarmEnable; }