Publish the message to the queue. `aio-pika` uses `publisher confirms`_ extension for message delivery. .. _publisher confirms: https

:param name: queue name :param durable: Durability (queue survive broker restart) :param exclusive: Makes this queue exclusi

Send basic.ack is used for positive acknowledgements .. note:: This method looks like a blocking-method, but actually it just

A binding is a relationship between an exchange and a queue. This can be simply read as: the queue is interested in messages from this

Creates a new task for the worker

Context manager for processing the message >>> async def on_message_received(message: IncomingMessage): ... async with mes

Returns an iterator for async for expression. Full example: .. code-block:: python import aio_pika async d

Start to consuming the :class:`Queue`. :param timeout: :class:`asyncio.TimeoutError` will be raises when the Future w

Make connection to the broker. Example: .. code-block:: python import aio_pika async def main(): connection =

Method creates a queue with name which equal of `method_name` argument. Then subscribes this queue. :param method_name: Method name

Delete the queue. :param if_unused: Perform delete only when unused :param if_empty: Perform delete only when empty :param ti

Create a container and return its ID.

Declare an exchange. :param name: string with exchange name or :class:`aio_pika.exchange.Exchange` instance :par

Remove binding from exchange for this :class:`Queue` instance :param exchange: :class:`aio_pika.exchange.Exchange` instance :param ro

This method cancels a consumer. This does not affect already delivered messages, but it does mean the server will not send any more me

When `requeue=True` the message will be returned to queue. Otherwise, message will be dropped. .. note:: This method look

Cancels subscription to the method-queue. :param func: Function

Make connection to the broker. Example: .. code-block:: python import aio_pika async def main(): connection =

With ``ensure=True``, it's a shortcut for ``.declare_exchange(..., passive=True)``; otherwise, it returns an exchange instanc

With ``ensure=True``, it's a shortcut for ``.declare_queue(..., passive=True)``; otherwise, it returns a queue instance witho

Creates a new :class:`Worker` instance.

Set lock flag to `True`

Remove a container.

Declare queue. :param timeout: execution timeout :return: :class:`None`

Call remote method and awaiting result. :param method_name: Name of method :param kwargs: Methos kwargs :param expiration:

Creates a new instance of :class:`aio_pika.patterns.RPC`. You should use this method instead of :func:`__init__`, because :func:`creat

Start a container.

Consume with retry on channel errors. Waits for channel to be ready before consuming, with backoff delay between retries to prevent C