celery routing - with priorities

494 Views Asked by At

Setup: celery 4.1, broker: RabbitMQ 3.6.5, backend Redis.

From the Documentation, there are several ways for routing:

Option 1 Automatic Routing:

task_routes = {
        'import_feed_task': {
            'queue': 'feed_tasks',
            'routing_key': 'feed_tasks',
        },
}

Option 2 Special Routing:

task_queues = [
    Queue('feed_tasks', Exchange('feed_tasks'), routing_key='feed_tasks',
          queue_arguments={'x-max-priority': 10},
]

I want to use the priority (queue_arguments={'x-max-priority': 10}) within the first option. Is it possible/supported?

0

There are 0 best solutions below