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)