diff --git a/zerver/lib/queue.py b/zerver/lib/queue.py index cd0e5e1ab0..8e4e08cbd3 100644 --- a/zerver/lib/queue.py +++ b/zerver/lib/queue.py @@ -187,7 +187,7 @@ class TornadoQueueClient(SimpleQueueClient): self.connection = ExceptionFreeTornadoConnection( self._get_parameters(), on_open_callback = self._on_open, - stop_ioloop_on_close = False) + ) self.connection.add_on_close_callback(self._on_connection_closed) def _reconnect(self) -> None: