Skip to content

Commit 899a1b5

Browse files
authored
[ISSUE #10023] Remove duplicate shutdown and rejection handler calls for routeThreadPoolExecutor (#10024)
1 parent 2eb537c commit 899a1b5

1 file changed

Lines changed: 0 additions & 3 deletions

File tree

proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,6 @@ protected GrpcMessagingApplication(GrpcMessagingActivity grpcMessagingActivity,
139139
protected void init() {
140140
GrpcTaskRejectedExecutionHandler rejectedExecutionHandler = new GrpcTaskRejectedExecutionHandler();
141141
this.routeThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
142-
this.routeThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
143142
this.producerThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
144143
this.consumerThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
145144
this.clientManagerThreadPoolExecutor.setRejectedExecutionHandler(rejectedExecutionHandler);
@@ -456,8 +455,6 @@ public void onCompleted() {
456455
@Override
457456
public void shutdown() throws Exception {
458457
this.grpcMessagingActivity.shutdown();
459-
460-
this.routeThreadPoolExecutor.shutdown();
461458
this.routeThreadPoolExecutor.shutdown();
462459
this.producerThreadPoolExecutor.shutdown();
463460
this.consumerThreadPoolExecutor.shutdown();

0 commit comments

Comments
 (0)