diff --git a/faststream/redis/message.py b/faststream/redis/message.py index 0abde06a19..8bce4005c8 100644 --- a/faststream/redis/message.py +++ b/faststream/redis/message.py @@ -130,6 +130,22 @@ async def ack( await redis.xack(channel, group, *ids) # type: ignore[no-untyped-call] await super().ack() + @override + async def nack( + self, + redis: Optional["Redis[bytes]"] = None, + group: Optional[str] = None, + ) -> None: + await super().nack() + + @override + async def reject( + self, + redis: Optional["Redis[bytes]"] = None, + group: Optional[str] = None, + ) -> None: + await super().reject() + class RedisStreamMessage(_RedisStreamMessageMixin[DefaultStreamMessage]): pass