This commit is contained in:
parent
d9d0dcdbaf
commit
50391d8b2f
@ -44,9 +44,7 @@ def setup_rabbit() -> None:
|
|||||||
socket_timeout=5))
|
socket_timeout=5))
|
||||||
channel = connection.channel()
|
channel = connection.channel()
|
||||||
channel.exchange_declare(exchange=config.RABBIT_EXCHANGE,
|
channel.exchange_declare(exchange=config.RABBIT_EXCHANGE,
|
||||||
exchange_type='fanout',
|
exchange_type='fanout')
|
||||||
durable=True,
|
|
||||||
auto_delete=False)
|
|
||||||
queue = channel.queue_declare(durable=True, auto_delete=True, queue=uuid.uuid4().urn.split(':')[2],
|
queue = channel.queue_declare(durable=True, auto_delete=True, queue=uuid.uuid4().urn.split(':')[2],
|
||||||
exclusive=True).method.queue
|
exclusive=True).method.queue
|
||||||
channel.queue_bind(exchange=config.RABBIT_EXCHANGE, queue=queue)
|
channel.queue_bind(exchange=config.RABBIT_EXCHANGE, queue=queue)
|
||||||
|
Loading…
Reference in New Issue
Block a user