(rocketmq) branch develop updated: [ISSUE #7760] make timerSkipUnknownError can be set by config file

[jinrongtong]

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;
     }