RabbitRouter

def include_router(self, router: "BrokerRouter[PublisherKeyType, MsgType]") -> None:
    """Includes a router in the current object.

    Args:
        router: The router to be included.

    Returns:
        None
    !!! note

        The above docstring is autogenerated by docstring-gen library (https://docstring-gen.airt.ai)
    """
    for h in router._handlers:
        self.subscriber(*h.args, **h.kwargs)(h.call)

    for p in router._publishers.values():
        p = self._update_publisher_prefix(self.prefix, p)
        key = self._get_publisher_key(p)
        self._publishers[key] = self._publishers.get(key, p)

def include_routers(
    self, *routers: "BrokerRouter[PublisherKeyType, MsgType]"
) -> None:
    """Includes routers in the object.

    Args:
        *routers: Variable length argument list of routers to include.

    Returns:
        None
    !!! note

        The above docstring is autogenerated by docstring-gen library (https://docstring-gen.airt.ai)
    """
    for r in routers:
        self.include_router(r)

@abstractmethod
def publisher(
    self,
    subj: str,
    *args: Any,
    **kwargs: Any,
) -> BasePublisher[MsgType]:
    """Publishes a message.

    Args:
        subj: Subject of the message
        *args: Additional arguments
        **kwargs: Additional keyword arguments

    Returns:
        The published message

    Raises:
        NotImplementedError: If the method is not implemented
    !!! note

        The above docstring is autogenerated by docstring-gen library (https://docstring-gen.airt.ai)
    """
    raise NotImplementedError()

@override
def subscriber(  # type: ignore[override]
    self,
    queue: Union[str, RabbitQueue],
    *broker_args: Any,
    **broker_kwargs: Any,
) -> Callable[
    [Callable[P_HandlerParams, T_HandlerReturn]],
    HandlerCallWrapper[IncomingMessage, P_HandlerParams, T_HandlerReturn],
]:
    """A function to subscribe to a RabbitMQ queue.

    Args:
        self : the instance of the class
        queue : the queue to subscribe to, can be a string or a RabbitQueue object
        *broker_args : additional arguments for the broker
        **broker_kwargs : additional keyword arguments for the broker

    Returns:
        A callable object that wraps the handler function for the incoming messages from the queue.

    Raises:
        TypeError: If the queue is not a string or a RabbitQueue object
    !!! note

        The above docstring is autogenerated by docstring-gen library (https://docstring-gen.airt.ai)
    """
    q = RabbitQueue.validate(queue)
    new_q = model_copy(q, update={"name": self.prefix + q.name})
    return self._wrap_subscriber(new_q, *broker_args, **broker_kwargs)