Back to Celery

Celery.App.Amqp

docs/reference/celery.app.amqp.rst

5.6.31.3 KB
Original Source

.. currentmodule:: celery.app.amqp

.. automodule:: celery.app.amqp

.. contents::
    :local:

AMQP
----

.. autoclass:: AMQP

    .. attribute:: Connection

        Broker connection class used. Default is :class:`kombu.Connection`.

    .. attribute:: Consumer

        Base Consumer class used. Default is :class:`kombu.Consumer`.

    .. attribute:: Producer

        Base Producer class used. Default is :class:`kombu.Producer`.

    .. attribute:: queues

        All currently defined task queues (a :class:`Queues` instance).

    .. attribute:: argsrepr_maxsize

        Max size of positional argument representation used for logging
        purposes. Default is 1024.

    .. attribute:: kwargsrepr_maxsize

        Max size of keyword argument representation used for logging
        purposes. Default is 1024.

    .. automethod:: Queues
    .. automethod:: Router
    .. automethod:: flush_routes

    .. autoattribute:: create_task_message
    .. autoattribute:: send_task_message
    .. autoattribute:: default_queue
    .. autoattribute:: default_exchange
    .. autoattribute:: producer_pool
    .. autoattribute:: router
    .. autoattribute:: routes

Queues
------

.. autoclass:: Queues
    :members:
    :undoc-members: