blob: ccdc3f2c7b84f3b9e147599d15be6ff4ac70f6ec (
plain)
1
2
3
4
5
6
7
8
|
from __future__ import absolute_import, unicode_literals
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')]
|
