Celery leaves you with the impression that RabbitMQ queues are getting mirrored if you set CELERY_QUEUE_HA_POLICY = 'all'.
This does not make queues mirrored in RabbitMQ 3 (released 2012).
The required policy string was changed from x-ha-policy: all to ha-mode: all:
http://www.rabbitmq.com/blog/2012/11/19/breaking-things-with-rabbitmq-3-0/
Problematic code in current master:
|
def _set_ha_policy(self, args): |