paulmataruso/zulip
1
0
Fork 0
mirror of https://github.com/zulip/zulip.git synced 2025-11-05 22:43:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

requirements: Upgrade to Tornado 6.

Browse Source 
Fixes #8913.

Signed-off-by: Anders Kaseorg <anders@zulip.com>
(cherry picked from commit 7acb642fa5)
This commit is contained in:
Anders Kaseorg
2022-03-17 13:42:25 -07:00
committed by Tim Abbott
parent 9362158e04
commit e124464fea
11 changed files with 115 additions and 68 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
zerver/lib/queue.py
View File

@@ -302,7 +302,7 @@ class TornadoQueueClient(QueueClient[Channel]):
"TornadoQueueClient couldn't connect to RabbitMQ, retrying in %d secs...",
retry_secs,
)
ioloop.IOLoop.instance().call_later(retry_secs, self._reconnect)
ioloop.IOLoop.current().call_later(retry_secs, self._reconnect)
def _on_connection_closed(
self, connection: pika.connection.Connection, reason: Exception
@@ -315,7 +315,7 @@ class TornadoQueueClient(QueueClient[Channel]):
"TornadoQueueClient lost connection to RabbitMQ, reconnecting in %d secs...",
retry_secs,
)
ioloop.IOLoop.instance().call_later(retry_secs, self._reconnect)
ioloop.IOLoop.current().call_later(retry_secs, self._reconnect)
def _on_open(self, connection: pika.connection.Connection) -> None:
assert self.connection is not None