diff --git a/rocketmq-remoting/src/request_processor/default_request_processor.rs b/rocketmq-remoting/src/request_processor/default_request_processor.rs index 310537d2..31777acd 100644 --- a/rocketmq-remoting/src/request_processor/default_request_processor.rs +++ b/rocketmq-remoting/src/request_processor/default_request_processor.rs @@ -25,6 +25,7 @@ use crate::Result; pub struct DefaultRemotingRequestProcessor; impl RequestProcessor for DefaultRemotingRequestProcessor { + #[inline] async fn process_request( &mut self, _channel: Channel,