The mandatory is the flag for this kind of situation, but in Kombu is not supported [1].
Check if a queue exists for each single publish dorps the performances drastically.
I would work to implement the mandatory flag and handle the important messages.
The mandatory is the flag for this kind of situation, but in Kombu is not supported [1].
Check if a queue exists for each single publish dorps the performances drastically.
I would work to implement the mandatory flag and handle the important messages.
https:/ /github. com/celery/ kombu/blob/ maswoter/ kombu/messaging .py#L129