Commit d08aaefd authored by Mustafa Gezen's avatar Mustafa Gezen 🏗
Browse files

Avoid leaking amqp credentials

parent 1c1fe070
......@@ -44,7 +44,7 @@ async def init_channel(loop) -> None:
global channel
global connection
connection = await aio_pika.connect_robust(settings.broker_url, loop=loop)"[*] Connected to {}".format(settings.broker_url))"[*] Connected to amqp")
channel = await
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment