15cfa253cf756ee0e9d011009a870d79a4c961d1,studio/rabbit_queue.py,RMQueue,on_connection_closed,#RMQueue#Any#Any#,99

Before Change

                self._connection.ioloop.stop()
            else:
                // retry in 5 seconds
                self._logger.info("connection closed, retry in 5 seconds: " +
                                  repr(reason))
                self._connection.ioloop.call_later(5, self._reconnect)

    def _reconnect(self):

After Change

        :param Exception reason: why the connection was closed

        
        self._logger.info("connection to queue {0} closed. Reason: {1}"
                          .format(self._queue, repr(reason)))
        with self._rmq_lock:
            if self._stopping:
                // If we are here, it means we are doing

Instances