diff options
Diffstat (limited to 'kombu/transport/consul.py')
| -rw-r--r-- | kombu/transport/consul.py | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/kombu/transport/consul.py b/kombu/transport/consul.py index 7ace52f6..370a4302 100644 --- a/kombu/transport/consul.py +++ b/kombu/transport/consul.py @@ -97,9 +97,11 @@ class Channel(virtual.Channel): read-consistency between the nodes. Arguments: + --------- queue (str): The name of the Queue. - Returns: + Returns + ------- str: The ID of the session. """ try: @@ -134,13 +136,16 @@ class Channel(virtual.Channel): means that they have to wait before the lock is released. Arguments: + --------- queue (str): The name of the Queue. raising (Exception): Set custom lock error class. - Raises: + Raises + ------ LockError: if the lock cannot be acquired. - Returns: + Returns + ------- bool: success? """ self._acquire_lock(queue, raising=raising) @@ -170,6 +175,7 @@ class Channel(virtual.Channel): It does so by simply removing the lock key in Consul. Arguments: + --------- queue (str): The name of the queue we want to release the lock from. """ @@ -182,6 +188,7 @@ class Channel(virtual.Channel): Will release all locks it still might hold. Arguments: + --------- queue (str): The name of the Queue. """ logger.debug('Destroying session %s', self.queues[queue]['session_id']) |