mirror of https://github.com/celery/kombu.git
Adds autodoc for kombu.pools
This commit is contained in:
parent
59fb3a649c
commit
914f2665c5
|
@ -30,6 +30,7 @@
|
|||
kombu.transport.virtual.scheduling
|
||||
kombu.serialization
|
||||
kombu.compression
|
||||
kombu.pools
|
||||
kombu.abstract
|
||||
kombu.syn
|
||||
kombu.utils
|
||||
|
|
|
@ -0,0 +1,11 @@
|
|||
==========================================================
|
||||
General Pools - kombu.pools
|
||||
==========================================================
|
||||
|
||||
.. contents::
|
||||
:local:
|
||||
.. currentmodule:: kombu.pools
|
||||
|
||||
.. automodule:: kombu.pools
|
||||
:members:
|
||||
:undoc-members:
|
|
@ -174,6 +174,7 @@ class test_Channel(unittest.TestCase):
|
|||
durable=False, auto_delete=True)
|
||||
|
||||
def test_exchange_delete(self, ex="test_exchange_delete"):
|
||||
|
||||
class PurgeChannel(virtual.Channel):
|
||||
purged = []
|
||||
|
||||
|
|
|
@ -272,7 +272,6 @@ class Channel(virtual.Channel):
|
|||
queue or ""]))
|
||||
self._avail_client.delete(queue)
|
||||
|
||||
|
||||
def _has_queue(self, queue, **kwargs):
|
||||
return self._avail_client.exists(queue)
|
||||
|
||||
|
|
Loading…
Reference in New Issue