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
47
48
49
50
51
52
53
54
55
56
|
.. 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:
|
