'Called when the connection is closed remotely via Connection.Close
frame from broker.
:param pika.frame.Method method_frame: The Connection.Close frame'

def _on_connection_close(self, method_frame):

    LOGGER.debug('_on_connection_close:    frame=%s', method_frame)
    self.closing = (method_frame.method.reply_code, method_frame.method.reply_text)
    self._on_terminate(self.closing[0], self.closing[1])
