[ISSUE #111]🔊Add some print logs (#112)

mxsm · Jan 26, 2024 · e07791c · e07791c
1 parent 5a9e829
commit e07791c
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/rocketmq-namesrv/src/processor/default_request_processor.rs b/rocketmq-namesrv/src/processor/default_request_processor.rs
@@ -63,7 +63,7 @@ use rocketmq_remoting::{
     },
     runtime::processor::RequestProcessor,
 };
-use tracing::warn;
+use tracing::{info, warn};
 
 use crate::{route::route_info_manager::RouteInfoManager, KVConfigManager};
 
@@ -81,6 +81,11 @@ impl RequestProcessor for DefaultRequestProcessor {
     ) -> RemotingCommand {
         let code = request.code();
         let broker_request_code = RequestCode::value_of(code);
+        info!(
+            "Received request code:{}-{:?}",
+            code,
+            broker_request_code.as_ref()
+        );
         match broker_request_code {
             Some(RequestCode::PutKvConfig) => self.put_kv_config(request),
             Some(RequestCode::GetKvConfig) => self.get_kv_config(request),