(rocketmq) branch develop updated: [ISSUE #8232] Fix the issue that proxy remoting thread pool isolation does not take effect (#8233)

[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 ed410f37dd [ISSUE #8232] Fix the issue that proxy remoting thread pool 
isolation does not take effect (#8233)
ed410f37dd is described below

commit ed410f37ddf8867a0e38d4fc384f9c9e1dc05103
Author: Liu Shengzhong <szliu0...@gmail.com>
AuthorDate: Tue May 13 13:56:59 2025 +0800

    [ISSUE #8232] Fix the issue that proxy remoting thread pool isolation does 
not take effect (#8233)
---
 .../org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java
 
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java
index c9acf728a3..3fae056a2a 100644
--- 
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java
+++ 
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java
@@ -122,7 +122,6 @@ public class RemotingProtocolServer implements 
StartAndShutdown, RemotingProxyOu
         } else {
             this.defaultRemotingServer = new 
NettyRemotingServer(defaultServerConfig, this.clientHousekeepingService);
         }
-        this.registerRemotingServer(this.defaultRemotingServer);
 
         this.sendMessageExecutor = ThreadPoolMonitor.createAndMonitor(
             config.getRemotingSendMessageThreadPoolNums(),
@@ -188,6 +187,8 @@ public class RemotingProtocolServer implements 
StartAndShutdown, RemotingProxyOu
             new 
ThreadFactoryBuilder().setNameFormat("RemotingServerScheduler-%d").build()
         );
         this.timerExecutor.scheduleAtFixedRate(this::cleanExpireRequest, 10, 
10, TimeUnit.SECONDS);
+
+        this.registerRemotingServer(this.defaultRemotingServer);
     }
 
     protected void registerRemotingServer(RemotingServer remotingServer) {