Fix parameters for on_close callback

Some of the older documentation was apparently wrong.

(imported from commit 9ebf9d1a72c8b230563f1883d63c26212eb80e22)
This commit is contained in:
Zev Benjamin 2013-10-08 18:35:58 -04:00
parent 46350c5dd8
commit 2c4a1912e8
1 changed files with 1 additions and 1 deletions

View File

@ -181,7 +181,7 @@ class TornadoQueueClient(SimpleQueueClient):
self._reconnect_consumer_callbacks() self._reconnect_consumer_callbacks()
self.log.info('TornadoQueueClient connected') 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...") self.log.warning("TornadoQueueClient lost connection to RabbitMQ, reconnecting...")
from tornado import ioloop from tornado import ioloop