0

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?

0

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.