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

TornadoQueueClient: Don't stop the Tornado I/O loop on RabbitMQ disconnect

Browse Source 
Requires Pika 0.9.6 or later.

(imported from commit 316ab9f2a6b5c2a25ae8584e2604222b33e0dec3)
This commit is contained in:
Keegan McAllister
2013-01-28 18:00:24 -05:00
committed by Leo Franchi
parent 6ffc2bbe65
commit 4baeaaa532
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
zephyr/lib/queue.py
View File

@@ -77,10 +77,8 @@ class TornadoQueueClient(SimpleQueueClient):
def _connect(self):
self.connection = pika.adapters.TornadoConnection(
self._get_parameters(),
on_open_callback = self._on_open)
# Docs suggest we should also pass stop_ioloop_on_close = False, but
# my version of TornadoConnection doesn't recognize it.
on_open_callback = self._on_open,
stop_ioloop_on_close = False)
def _on_open(self, connection):
self.connection.channel(