'Disconnect from RabbitMQ. If there are any open channels, it will
attempt to close them prior to fully disconnecting. Channels which
have active consumers will attempt to send a Basic.Cancel to RabbitMQ
to cleanly stop the delivery of messages prior to closing the channel.
:param int reply_code: The code number for the close
:param str reply_text: The text reason for the close'

def close(self, reply_code=200, reply_text='Normal    shutdown'):

    if (self.is_closing or self.is_closed):
        LOGGER.warning('Suppressing    close    request    on    %s', self)
        return
    self._close_channels(reply_code, reply_text)
    self._set_connection_state(self.CONNECTION_CLOSING)
    LOGGER.info('Closing    connection    (%s):    %s', reply_code, reply_text)
    self.closing = (reply_code, reply_text)
    if (not self._channels):
        self._on_close_ready()
    else:
        LOGGER.info('Connection.close    is    waiting    for    %d    channels    to    close:    %s', len(self._channels), self)
