I have a queue in RabbitMQ broker called queue-ktm of type quorum. There are tasks pushed to this queue and available.
I run a celery worker to consume from this queue with following configuration:
app.conf.task_queues.extend([
Queue("queue-ktm", exchange=Exchange('exchange-ktm', type='topic'), queue_arguments={'x-queue-type': 'quorum'}, routing_key='#'),
])
There's a binding to this queue from exchange exchange-ktm and key #.
I run the worker command:
celery -A celery_app.celery_app worker -Q queue-ktm --loglevel=debug
the worker lists the queue:
[queues]
.> queue-ktm exchange=exchange-ktm(topic) key=#
But the worker is not processing any task from the queue.
Checked the queue and Consumers are 0.
This became the issue when I switched from classic to quorum type.
Can anyone point the issue?