From f0ea8f60423e71032e4ab57ee683cbc796202d0f Mon Sep 17 00:00:00 2001
From: amigin <amigin@gmail.com>
Date: Tue, 18 Feb 2025 14:38:21 +0200
Subject: [PATCH] Fixes

---
 my-service-bus-abstractions/src/subscriber/messages_reader.rs | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/my-service-bus-abstractions/src/subscriber/messages_reader.rs b/my-service-bus-abstractions/src/subscriber/messages_reader.rs
index 8d3c782..feb78f9 100644
--- 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>>> {