blob: bee729df39ac773ca94814385efb4849da385008 (
plain)
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
.. currentmodule:: kombu.simple
.. automodule:: kombu.simple
.. contents::
:local:
Persistent
----------
.. autoclass:: SimpleQueue
.. attribute:: channel
Current channel
.. attribute:: producer
:class:`~kombu.Producer` used to publish messages.
.. attribute:: consumer
:class:`~kombu.Consumer` used to receive messages.
.. attribute:: no_ack
flag to enable/disable acknowledgements.
.. attribute:: queue
:class:`~kombu.entity.Queue` to consume from (if consuming).
.. attribute:: queue_opts
Additional options for the queue declaration.
.. attribute:: exchange_opts
Additional options for the exchange declaration.
.. automethod:: get
.. automethod:: get_nowait
.. automethod:: put
.. automethod:: clear
.. automethod:: __len__
.. automethod:: qsize
.. automethod:: close
Buffer
------
.. autoclass:: SimpleBuffer
.. attribute:: channel
Current channel
.. attribute:: producer
:class:`~kombu.Producer` used to publish messages.
.. attribute:: consumer
:class:`~kombu.Consumer` used to receive messages.
.. attribute:: no_ack
flag to enable/disable acknowledgements.
.. attribute:: queue
:class:`~kombu.entity.Queue` to consume from (if consuming).
.. attribute:: queue_opts
Additional options for the queue declaration.
.. attribute:: exchange_opts
Additional options for the exchange declaration.
.. automethod:: get
.. automethod:: get_nowait
.. automethod:: put
.. automethod:: clear
.. automethod:: __len__
.. automethod:: qsize
.. automethod:: close
|
