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

Add on-close callback immediately after creating

Browse Source 
(imported from commit 221f8c6306ef9b6c658d10b72e15dcfba83017e0)
This commit is contained in:
Leo Franchi
2013-04-17 11:16:23 -04:00
parent a54e8fee1c
commit 4adf2d5c26
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
zephyr/lib/queue.py
View File

@@ -116,6 +116,7 @@ class TornadoQueueClient(SimpleQueueClient):
self._get_parameters(), self._get_parameters(),
on_open_callback = self._on_open, on_open_callback = self._on_open,
stop_ioloop_on_close = False) stop_ioloop_on_close = False)
self.connection.add_on_close_callback(self._on_connection_closed)
def _reconnect(self, on_open_cb = None): def _reconnect(self, on_open_cb = None):
self.connection = None self.connection = None
@@ -124,7 +125,6 @@ class TornadoQueueClient(SimpleQueueClient):
self._connect(on_open_cb) self._connect(on_open_cb)
def _on_open(self, connection): def _on_open(self, connection):
self.connection.add_on_close_callback(self._on_connection_closed)
self.connection.channel( self.connection.channel(
on_open_callback = self._on_channel_open) on_open_callback = self._on_channel_open)