diff --git a/faststream/nats/message.py b/faststream/nats/message.py index 0f104a3310..f0d1c8d7f3 100644 --- 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,