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)