channel = await get_channel()
 
    exchange = await channel.declare_exchange(
        "direct", auto_delete=True
    )
 
    queue = await channel.declare_queue(
        consumer, auto_delete=True
    )await message.ack())      for b in file_3:
    if b.endswith(".session"):
        file_4.append(b)