def close_connection(self, connection):
        connection.client = None
        connection.close()
Close the AMQP broker connection.
dataset/ETHPy150Open celery/kombu/kombu/transport/amqplib.py/Transport.close_connection