diff --git a/rocketmq-broker/src/processor/change_invisible_time_processor.rs b/rocketmq-broker/src/processor/change_invisible_time_processor.rs
index abb737a1..a91645c9 100644
--- a/rocketmq-broker/src/processor/change_invisible_time_processor.rs
+++ b/rocketmq-broker/src/processor/change_invisible_time_processor.rs
@@ -1,30 +1,35 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-use rocketmq_remoting::runtime::connection_handler_context::ConnectionHandlerContext;
-
-#[derive(Default)]
-pub struct ChangeInvisibleTimeProcessor {}
-
-impl ChangeInvisibleTimeProcessor {
-    fn process_request(
-        &self,
-        _ctx: ConnectionHandlerContext,
-        _request: rocketmq_remoting::protocol::remoting_command::RemotingCommand,
-    ) -> rocketmq_remoting::protocol::remoting_command::RemotingCommand {
-        todo!()
-    }
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * 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 ChangeInvisibleTimeProcessor {}
+
+impl ChangeInvisibleTimeProcessor {
+    pub async fn process_request(
+        &mut self,
+        _channel: Channel,
+        _ctx: ConnectionHandlerContext,
+        _request_code: RequestCode,
+        _request: RemotingCommand,
+    ) -> crate::Result<Option<RemotingCommand>> {
+        unimplemented!("ChangeInvisibleTimeProcessor process_request")
+    }
+}