[ISSUE #1644]♻️Refactor PollingInfoProcessor#process_request method s…

…ignature🔥
mxsm · Dec 7, 2024 · 85cdedb · 85cdedb
1 parent c9e9c1d
commit 85cdedb
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/rocketmq-broker/src/processor/polling_info_processor.rs b/rocketmq-broker/src/processor/polling_info_processor.rs
@@ -14,18 +14,22 @@
  * 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;
 
 #[derive(Default)]
 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<Option<RemotingCommand>> {
         todo!()
     }
 }