File: celery.app.amqp.rst

package info (click to toggle)
celery 4.2.1-3
  • links: PTS, VCS
  • area: main
  • in suites: buster
  • size: 6,136 kB
  • sloc: python: 47,677; sh: 772; makefile: 226
file content (46 lines) | stat: -rw-r--r-- 1,066 bytes parent folder | download
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
.. 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).

        .. 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: