Revision fde763c3 db/db_controller.py
b/db/db_controller.py | ||
---|---|---|
72 | 72 |
|
73 | 73 |
def declare_queues(chan): |
74 | 74 |
chan.exchange_declare(exchange=settings.EXCHANGE_GANETI, type="topic", durable=True, auto_delete=False) |
75 |
chan.exchange_declare(exchange=settings.EXCHANGE_CRON, type="topic", durable=True, auto_delete=False) |
|
76 |
chan.exchange_declare(exchange=settings.EXCHANGE_API, type="topic", durable=True, auto_delete=False) |
|
77 |
|
|
75 | 78 |
chan.queue_declare(queue=settings.QUEUE_GANETI_EVENTS, durable=True, exclusive=False, auto_delete=False) |
79 |
chan.queue_declare(queue=settings.QUEUE_CRON_CREDITS, durable=True, exclusive=False, auto_delete=False) |
|
80 |
chan.queue_declare(queue=settings.QUEUE_API_EMAIL, durable=True, exclusive=False, auto_delete=False) |
|
81 |
chan.queue_declare(queue=settings.QUEUE_CRON_EMAIL, durable=True, exclusive=False, auto_delete=False) |
|
76 | 82 |
|
77 | 83 |
def init_devel(): |
78 | 84 |
chan = open_channel() |
Also available in: Unified diff