code: def on_rabbitmq_close(self, reply_code, reply_text):
          
          global rabbitmq_connection
          LOGGER.warning('RabbitMQ has disconnected (%s): %s',
                         reply_code, reply_text)
          rabbitmq_connection = None
          self._set_rabbitmq_channel(None)
          self._connect_to_rabbitmq()
docs: Called when RabbitMQ has been connected to.
  
          :param int reply_code: The code for the disconnect
          :param str reply_text: The disconnect reason