[ISSUE #2277]🚀AckMessageProcessor and BroadcastOffsetManager add star…

…t method (#2278)
mxsm · Jan 16, 2025 · a3e692a · a3e692a
1 parent 1c3b29c
commit a3e692a
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/rocketmq-broker/src/offset/manager/broadcast_offset_manager.rs b/rocketmq-broker/src/offset/manager/broadcast_offset_manager.rs
@@ -21,6 +21,10 @@ pub struct BroadcastOffsetManager {}
 
 #[allow(unused_variables)]
 impl BroadcastOffsetManager {
+    pub fn start(&mut self) {
+        warn!("BroadcastOffsetManager started is not implemented");
+    }
+
     pub fn query_init_offset(
         &self,
         topic: &str,

diff --git a/rocketmq-broker/src/processor/ack_message_processor.rs b/rocketmq-broker/src/processor/ack_message_processor.rs
@@ -119,6 +119,10 @@ where
             )),
         }
     }
+
+    pub fn start(&mut self) {
+        warn!("AckMessageProcessor started unimplemented, need to be implemented");
+    }
 }
 
 impl<MS> AckMessageProcessor<MS>
-Original file line number
+Diff line change
@@ Expand Up / @@ -119,6 +119,10 @@ where @@
                 )),
             }
         }
+        pub fn start(&mut self) {
+            warn!("AckMessageProcessor started unimplemented, need to be implemented");
+        }
     }
     impl<MS> AckMessageProcessor<MS>
@@ Expand Down @@