(rocketmq) branch develop updated: [ISSUE #7902] fix:reput thread may quit by throwing error

[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 3c27bfe5ed [ISSUE #7902] fix:reput thread may quit by throwing error
3c27bfe5ed is described below

commit 3c27bfe5ed50406fc5c3f4e49face50160befa18
Author: Humkum <1109939...@qq.com>
AuthorDate: Thu Mar 14 16:03:51 2024 +0800

    [ISSUE #7902] fix:reput thread may quit by throwing error
---
 store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java 
b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index 1392d64e34..cd7940e87d 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -2926,7 +2926,7 @@ public class DefaultMessageStore implements MessageStore {
                 try {
                     TimeUnit.MILLISECONDS.sleep(1);
                     this.doReput();
-                } catch (Exception e) {
+                } catch (Throwable e) {
                     DefaultMessageStore.LOGGER.warn(this.getServiceName() + " 
service has exception. ", e);
                 }
             }