cleanup interface [skip ci]

VikParuchuri · Jan 29, 2025 · a5af660 · a5af660
1 parent 0164959
commit a5af660
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/marker/batch/messages/base.py b/marker/batch/messages/base.py
@@ -2,6 +2,12 @@
 
 
 class MessageQueue(ABC):
+
+    @staticmethod
+    @abstractmethod
+    def config_options():
+        pass
+
     @abstractmethod
     def publish(self, topic: str, message: str):
         """Publish a message to a topic/queue."""
@@ -14,3 +20,8 @@ def consume(self, topic: str, callback):
         A callback function is called for each message.
         """
         pass
+
+    @abstractmethod
+    def ack(self, msg, **kwargs):
+        """Acknowledge a message."""
+        pass