Skip to content

ConsumerProtocol

faststream.redis.message.ConsumerProtocol #

Bases: Protocol

A protocol for Redis consumers.

xack async #

xack(name: str, groupname: str, *ids: bytes) -> None
Source code in faststream/redis/message.py 
126
127
async def xack(self, name: str, groupname: str, *ids: bytes) -> None:
    pass

xdel async #

xdel(name: str, *ids: bytes) -> None
Source code in faststream/redis/message.py 
129
130
async def xdel(self, name: str, *ids: bytes) -> None:
    pass

xpending_range async #

xpending_range(
    name: str,
    groupname: str,
    min: bytes,
    max: bytes,
    count: int,
) -> list[dict[str, Any]]
Source code in faststream/redis/message.py 
132
133
134
135
async def xpending_range(
    self, name: str, groupname: str, min: bytes, max: bytes, count: int
) -> list[dict[str, Any]]:
    pass