RedisRoute

def __init__(
    self,
    call: Callable[..., "SendableMessage"]
    | Callable[..., Awaitable["SendableMessage"]],
    channel: Union[str, "PubSub"] | None = None,
    *,
    publishers: Iterable["RedisPublisher"] = (),
    list: Union[str, "ListSub"] | None = None,
    stream: Union[str, "StreamSub"] | None = None,
    dependencies: Iterable["Dependant"] = (),
    parser: Optional["CustomCallable"] = None,
    decoder: Optional["CustomCallable"] = None,
    middlewares: Sequence["SubscriberMiddleware[Any]"] = (),
    no_ack: bool = EMPTY,
    ack_policy: AckPolicy = EMPTY,
    no_reply: bool = False,
    title: str | None = None,
    description: str | None = None,
    include_in_schema: bool = True,
    max_workers: int | None = None,
) -> None:
    """Initialize the RedisRoute.

    Args:
        call:
            Message handler function to wrap the same with `@broker.subscriber(...)` way.
        channel:
            Redis PubSub object name to send message.
        publishers:
            Redis publishers to broadcast the handler result.
        list:
            Redis List object name to send message.
        stream:
            Redis Stream object name to send message.
        dependencies:
            Dependencies list (`[Dependant(),]`) to apply to the subscriber.
        parser:
            Parser to map original **aio_pika.IncomingMessage** Msg to FastStream one.
        decoder:
            Function to decode FastStream msg bytes body to python objects.
        middlewares:
            Subscriber middlewares to wrap incoming message processing. (Deprecated)
        no_ack:
            Whether to disable **FastStream** auto acknowledgement logic or not. (Deprecated)
        ack_policy:
            Acknowledgement policy of the handler.
        no_reply:
            Whether to disable **FastStream** RPC and Reply To auto responses or not.
        title:
            AsyncAPI subscriber object title.
        description:
            AsyncAPI subscriber object description. Uses decorated docstring as default.
        include_in_schema:
            Whetever to include operation in AsyncAPI schema or not.
        max_workers:
            Number of workers to process messages concurrently.
    """
    super().__init__(
        call,
        channel=channel,
        publishers=publishers,
        list=list,
        stream=stream,
        dependencies=dependencies,
        max_workers=max_workers,
        parser=parser,
        decoder=decoder,
        middlewares=middlewares,
        ack_policy=ack_policy,
        no_ack=no_ack,
        no_reply=no_reply,
        title=title,
        description=description,
        include_in_schema=include_in_schema,
    )