From 27ffa0cb5f1bad9df70c68eeaffe3381378446f8 Mon Sep 17 00:00:00 2001
From: parizval <anmolgoyal@gmail.com>
Date: Fri, 12 Sep 2025 19:39:16 +0530
Subject: [PATCH] refactor: ClientRequestProcessor#process_request use
 get_route_info_by_topic directly

---
 .../src/processor/client_request_processor.rs  | 18 ++++--------------
 1 file changed, 4 insertions(+), 14 deletions(-)

diff --git a/rocketmq-namesrv/src/processor/client_request_processor.rs b/rocketmq-namesrv/src/processor/client_request_processor.rs
index 12acb722..a17c1cb6 100644
--- a/rocketmq-namesrv/src/processor/client_request_processor.rs
+++ b/rocketmq-namesrv/src/processor/client_request_processor.rs
@@ -46,8 +46,8 @@ impl RequestProcessor for ClientRequestProcessor {
     #[inline]
     async fn process_request(
         &mut self,
-        channel: Channel,
-        ctx: ConnectionHandlerContext,
+        _channel: Channel,
+        _ctx: ConnectionHandlerContext,
         request: &mut RemotingCommand,
     ) -> rocketmq_error::RocketMQResult<Option<RemotingCommand>> {
         let request_code = RequestCode::from(request.code());
@@ -55,7 +55,8 @@ impl RequestProcessor for ClientRequestProcessor {
             "Name server ClientRequestProcessor Received request code: {:?}",
             request_code
         );
-        self.process_request_inner(channel, ctx, request_code, request)
+
+        self.get_route_info_by_topic(request)
     }
 }
 
@@ -68,17 +69,6 @@ impl ClientRequestProcessor {
         }
     }
 
-    #[inline]
-    fn process_request_inner(
-        &mut self,
-        _channel: Channel,
-        _ctx: ConnectionHandlerContext,
-        _request_code: RequestCode,
-        request: &mut RemotingCommand,
-    ) -> rocketmq_error::RocketMQResult<Option<RemotingCommand>> {
-        self.get_route_info_by_topic(request)
-    }
-
     fn get_route_info_by_topic(
         &self,
         request: &mut RemotingCommand,