Feature: add NatsMessage ack_sync method #1906

airtai · Nov 9, 2024 · 230d1ce · 230d1ce
1 parent 0d4c237
commit 230d1ce
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/faststream/nats/message.py b/faststream/nats/message.py
@@ -17,6 +17,11 @@ async def ack(self) -> None:
             await self.raw_message.ack()
         await super().ack()
 
+    def ack_sync(self) -> None:
+        if not self.raw_message._ackd:
+            self.raw_message.ack()
+        super().ack()
+
     async def nack(
         self,
         delay: Union[int, float, None] = None,