From 85cdedbdac474e97c62487fc97b92533f5c389d7 Mon Sep 17 00:00:00 2001 From: mxsm Date: Sat, 7 Dec 2024 20:08:38 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#1644]=E2=99=BB=EF=B8=8FRefactor=20Pol?= =?UTF-8?q?lingInfoProcessor#process=5Frequest=20method=20signature?= =?UTF-8?q?=F0=9F=94=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/processor/polling_info_processor.rs | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/rocketmq-broker/src/processor/polling_info_processor.rs b/rocketmq-broker/src/processor/polling_info_processor.rs index bc8fc039..0833cddb 100644 --- a/rocketmq-broker/src/processor/polling_info_processor.rs +++ b/rocketmq-broker/src/processor/polling_info_processor.rs @@ -14,6 +14,8 @@ * See the License for the specific language governing permissions and * limitations under the License. */ +use rocketmq_remoting::code::request_code::RequestCode; +use rocketmq_remoting::net::channel::Channel; use rocketmq_remoting::protocol::remoting_command::RemotingCommand; use rocketmq_remoting::runtime::connection_handler_context::ConnectionHandlerContext; @@ -21,11 +23,13 @@ use rocketmq_remoting::runtime::connection_handler_context::ConnectionHandlerCon pub struct PollingInfoProcessor {} impl PollingInfoProcessor { - fn process_request( - &self, + pub async fn process_request( + &mut self, + _channel: Channel, _ctx: ConnectionHandlerContext, + _request_code: RequestCode, _request: RemotingCommand, - ) -> RemotingCommand { + ) -> crate::Result> { todo!() } }