Fixes

MyJetTools · Feb 18, 2025 · f0ea8f6 · f0ea8f6
1 parent 0b5ab21
commit f0ea8f6
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/my-service-bus-abstractions/src/subscriber/messages_reader.rs b/my-service-bus-abstractions/src/subscriber/messages_reader.rs
@@ -80,6 +80,10 @@ impl<TMessageModel: MySbMessageDeserializer<Item = TMessageModel>> MessagesReade
         let _ = self.delivered.remove(message_id);
     }
 
+    pub fn force_mark_as_delivered(&mut self) {
+        self.handle_current_messages_as_ok();
+    }
+
     pub fn get_all<'s>(
         &'s mut self,
     ) -> Option<std::collections::vec_deque::IterMut<'s, MySbDeliveredMessage<TMessageModel>>> {