diff --git a/zerver/lib/queue.py b/zerver/lib/queue.py
index bfcc1bec20..a4da11a564 100644
--- a/zerver/lib/queue.py
+++ b/zerver/lib/queue.py
@@ -181,7 +181,7 @@ class TornadoQueueClient(SimpleQueueClient):
         self._reconnect_consumer_callbacks()
         self.log.info('TornadoQueueClient connected')
 
-    def _on_connection_closed(self, method_frame):
+    def _on_connection_closed(self, connection, reply_code, reply_text):
         self.log.warning("TornadoQueueClient lost connection to RabbitMQ, reconnecting...")
         from tornado import ioloop