Oct 14, 2025 · Oct 20, 2025 · Oct 27, 2025 · Nov 5, 2025 · Nov 12, 2025 · Nov 14, 2025
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java b/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java

 public class ProxyStartup {
    private static final Logger log = LoggerFactory.getLogger(LoggerName.PROXY_LOGGER_NAME);
    /**
     * proxy components container, manager components with method start/shutdown/...
     * - gRPC thread pool executor
     * - message processor (wrap broker controller)
     * - grpc server
     * - remoting protocol server
     * - ...
     */
    private static final ProxyStartAndShutdown PROXY_START_AND_SHUTDOWN = new ProxyStartAndShutdown();

    private static class ProxyStartAndShutdown extends AbstractStartAndShutdown {
            // init thread pool monitor for proxy.
            initThreadPoolMonitor();

            // init business thread pool for grpc server
            ThreadPoolExecutor executor = createServerExecutor();

            // create message processor, wrap broker controller in local mode
            MessagingProcessor messagingProcessor = createMessagingProcessor();

            // tls cert update
Original file line number	Diff line number	Diff line change
Expand Up		@@ -55,6 +55,14 @@

		public class ProxyStartup {
		private static final Logger log = LoggerFactory.getLogger(LoggerName.PROXY_LOGGER_NAME);
		/**
		* proxy components container, manager components with method start/shutdown/...
		* - gRPC thread pool executor
		* - message processor (wrap broker controller)
		* - grpc server
		* - remoting protocol server
		* - ...
		*/
		private static final ProxyStartAndShutdown PROXY_START_AND_SHUTDOWN = new ProxyStartAndShutdown();

		private static class ProxyStartAndShutdown extends AbstractStartAndShutdown {
Expand All		@@ -73,8 +81,10 @@ public static void main(String[] args) {
		// init thread pool monitor for proxy.
		initThreadPoolMonitor();

		// init business thread pool for grpc server
		ThreadPoolExecutor executor = createServerExecutor();

		// create message processor, wrap broker controller in local mode
		MessagingProcessor messagingProcessor = createMessagingProcessor();

		// tls cert update
Expand Down