Work queue in queue_consumer.py is unbounded
Closed this issue · 1 comments
pacejackson commented
The work_queue created in queue_consumer.py is currently un-bounded. This means that if queue is very full, the kombu consumer will rapidly accept messages from RabbitMQ and fill the work_queue until the application runs out of memory.
To address this, we should set some value for maxsize when initializing the queue.