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>>> {