paulmataruso/zulip
1
0
Fork 0
mirror of https://github.com/zulip/zulip.git synced 2025-11-06 15:03:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix using SimpleQueueClient with multiple queues

Browse Source 
(imported from commit 18bda1430d76f8b436ad42f85d0ce3cab8fd8193)
This commit is contained in:
Zev Benjamin
2013-09-09 14:13:40 -04:00
parent f5761401b7
commit d7d17c993c
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
zerver/lib/queue.py
View File

@@ -43,14 +43,16 @@ class SimpleQueueClient(object):
def _generate_ctag(self, queue_name): def _generate_ctag(self, queue_name):
return "%s_%s" % (queue_name, str(random.getrandbits(16))) return "%s_%s" % (queue_name, str(random.getrandbits(16)))
def _reconnect_consumer_callback(self, queue, consumer):
self.log.info("Queue reconnecting saved consumer %s to queue %s" % (consumer, queue))
self.ensure_queue(queue, lambda: self.channel.basic_consume(consumer,
queue=queue,
consumer_tag=self._generate_ctag(queue)))
def _reconnect_consumer_callbacks(self): def _reconnect_consumer_callbacks(self):
for queue, consumers in self.consumers.items(): for queue, consumers in self.consumers.items():
for consumer in consumers: for consumer in consumers:
self.log.info("Queue reconnecting saved consumer %s to queue %s" % (consumer, queue)) self._reconnect_consumer_callback(queue, consumer)
self.ensure_queue(queue, lambda: self.channel.basic_consume(
consumer,
queue=queue,
consumer_tag=self._generate_ctag(queue)))
def close(self): def close(self):
if self.connection: if self.connection: