[ISSUE #1918] Catch throwable in PullMessageService thread run method (#9278)

fuyou001 · web-flow · commit 17d57cac7090 · 2025-04-04T14:56:00.000+08:00
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
@@ -135,7 +135,7 @@ public void run() {
                     this.pullMessage((PullRequest) messageRequest);
                 }
             } catch (InterruptedException ignored) {
-            } catch (Exception e) {
+            } catch (Throwable e) {
                 logger.error("Pull Message Service Run Method exception", e);
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -135,7 +135,7 @@ public void run() {`
`135`	`135`	`this.pullMessage((PullRequest) messageRequest);`
`136`	`136`	`}`
`137`	`137`	`} catch (InterruptedException ignored) {`
`138`		`- } catch (Exception e) {`
	`138`	`+ } catch (Throwable e) {`
`139`	`139`	`logger.error("Pull Message Service Run Method exception", e);`
`140`	`140`	`}`
`141`	`141`	`}`