(rocketmq) branch develop updated: [ISSUE #10023] Remove duplicate shutdown and rejection handler calls for routeThreadPoolExecutor (#10024)

[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 899a1b5520 [ISSUE #10023] Remove duplicate shutdown and rejection 
handler calls for routeThreadPoolExecutor (#10024)
899a1b5520 is described below

commit 899a1b552048d1cd4ad5b26e2d4f5668e9966af5
Author: wizcraft_kris <99409434+kris20030...@users.noreply.github.com>
AuthorDate: Tue Jan 20 14:09:02 2026 +0800

    [ISSUE #10023] Remove duplicate shutdown and rejection handler calls for 
routeThreadPoolExecutor (#10024)
---
 .../org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java    | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
 
b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
index 0b45dd7cf0..3429ad54e2 100644
--- 
a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
+++ 
b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
@@ -139,7 +139,6 @@ public class GrpcMessagingApplication extends 
MessagingServiceGrpc.MessagingServ
     protected void init() {
         GrpcTaskRejectedExecutionHandler rejectedExecutionHandler = new 
GrpcTaskRejectedExecutionHandler();
         
this.routeThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
-        
this.routeThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
         
this.producerThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
         
this.consumerThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
         
this.clientManagerThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
@@ -456,8 +455,6 @@ public class GrpcMessagingApplication extends 
MessagingServiceGrpc.MessagingServ
     @Override
     public void shutdown() throws Exception {
         this.grpcMessagingActivity.shutdown();
-
-        this.routeThreadPoolExecutor.shutdown();
         this.routeThreadPoolExecutor.shutdown();
         this.producerThreadPoolExecutor.shutdown();
         this.consumerThreadPoolExecutor.shutdown();