(rocketmq) branch develop updated: [ISSUE #1918] Catch throwable in PullMessageService thread run method (#9278)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin 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 17d57cac70 [ISSUE #1918] Catch throwable in PullMessageService thread 
run method (#9278)
17d57cac70 is described below

commit 17d57cac709088a5840921f01fede573fab670d6
Author: fuyou001 <yubao....@alibaba-inc.com>
AuthorDate: Fri Apr 4 14:56:00 2025 +0800

    [ISSUE #1918] Catch throwable in PullMessageService thread run method 
(#9278)
---
 .../org/apache/rocketmq/client/impl/consumer/PullMessageService.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
index ec6ede6bde..4300f20a76 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
@@ -135,7 +135,7 @@ public class PullMessageService extends ServiceThread {
                     this.pullMessage((PullRequest) messageRequest);
                 }
             } catch (InterruptedException ignored) {
-            } catch (Exception e) {
+            } catch (Throwable e) {
                 logger.error("Pull Message Service Run Method exception", e);
             }
         }