How to deal with ConnectionError about aio-pika HOT 1 CLOSED

import asyncio
import logging
from aio_pika import connect

logging.basicConfig(level=logging.DEBUG)

conn = None


def on_connection_closed(future):
    try:
        future.result()
    except:
        logging.exception("Oooops...")
    loop.stop()


async def rmq_connect():
    global conn
    loop = asyncio.get_event_loop()
    conn = await connect('amqp://guest:[email protected]/', loop=loop)
    conn.add_close_callback(on_connection_closed)


async def close():
    global conn
    await conn.close()

loop = asyncio.get_event_loop()
loop.run_until_complete(rmq_connect())

try:
    loop.run_forever()
except KeyboardInterrupt:
    pass
finally:
    loop.run_until_complete(close())

loop.close()