AioPikaFastProducer

async def publish(
    self,
    message: AioPikaSendableMessage = "",
    queue: Union[RabbitQueue, str] = "",
    exchange: Union[RabbitExchange, str, None] = None,
    *,
    routing_key: str = "",
    mandatory: bool = True,
    immediate: bool = False,
    timeout: TimeoutType = None,
    rpc: bool = False,
    rpc_timeout: Optional[float] = 30.0,
    raise_timeout: bool = False,
    persist: bool = False,
    reply_to: Optional[str] = None,
    **message_kwargs: Any,
) -> Union[aiormq.abc.ConfirmationFrameType, SendableMessage]:
    """Publish a message to a RabbitMQ queue.

    Args:
        message (AioPikaSendableMessage): The message to be published.
        queue (Union[RabbitQueue, str]): The queue to publish the message to.
        exchange (Union[RabbitExchange, str, None]): The exchange to publish the message to.
        routing_key (str): The routing key for the message.
        mandatory (bool): Whether the message is mandatory.
        immediate (bool): Whether the message should be delivered immediately.
        timeout (TimeoutType): The timeout for the operation.
        rpc (bool): Whether the message is for RPC.
        rpc_timeout (Optional[float]): The timeout for RPC.
        raise_timeout (bool): Whether to raise an exception on timeout.
        persist (bool): Whether the message should be persisted.
        reply_to (Optional[str]): The reply-to queue for RPC.
        **message_kwargs (Any): Additional keyword arguments for the message.

    Returns:
        Union[aiormq.abc.ConfirmationFrameType, SendableMessage]: The result of the publish operation.

    Raises:
        WRONG_PUBLISH_ARGS: If reply_to is not None when rpc is True.
    !!! note

        The above docstring is autogenerated by docstring-gen library (https://docstring-gen.airt.ai)
    """
    p_queue = RabbitQueue.validate(queue)

    context: AsyncContextManager[
        Optional[MemoryObjectReceiveStream[aio_pika.IncomingMessage]]
    ]
    if rpc is True:
        if reply_to is not None:
            raise WRONG_PUBLISH_ARGS
        else:
            context = _RPCCallback(
                self._rpc_lock,
                self.declarer.queues[RABBIT_REPLY],
            )
    else:
        context = _fake_context()

    async with context as response_queue:
        r = await self._publish(
            message=message,
            exchange=exchange,
            routing_key=routing_key or p_queue.routing or "",
            mandatory=mandatory,
            immediate=immediate,
            timeout=timeout,
            persist=persist,
            reply_to=RABBIT_REPLY if response_queue else reply_to,
            **message_kwargs,
        )

        if response_queue is None:
            return r

        else:
            msg: Optional[aio_pika.IncomingMessage] = None
            with timeout_scope(rpc_timeout, raise_timeout):
                msg = await response_queue.receive()

            if msg:  # pragma: no branch
                return await self._decoder(await self._parser(msg))

    return None