blob: a545b4c2df95f96368c539ee680d84d0bf2f1567 (
plain)
1
2
3
4
5
6
7
8
|
from __future__ import annotations
from kombu import Exchange, Queue
task_exchange = Exchange('tasks', type='direct')
task_queues = [Queue('hipri', task_exchange, routing_key='hipri'),
Queue('midpri', task_exchange, routing_key='midpri'),
Queue('lopri', task_exchange, routing_key='lopri')]
|
