fix code

mxsm · mxsm · commit bab7ba2f7ec6 · 2024-12-07T20:09:55.000+08:00
diff --git a/rocketmq-broker/src/processor/ack_message_processor.rs b/rocketmq-broker/src/processor/ack_message_processor.rs
@@ -14,16 +14,20 @@
  * 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 AckMessageProcessor {}
 
 impl AckMessageProcessor {
-    fn process_request(
-        &self,
+    pub async fn process_request(
+        &mut self,
+        _channel: Channel,
         _ctx: ConnectionHandlerContext,
+        _request_code: RequestCode,
         _request: RemotingCommand,
     ) -> crate::Result<Option<RemotingCommand>> {
         unimplemented!("AckMessageProcessor process_request")
