Skip to content

CELERY_QUEUE_HA_POLICY has no effect on RabbitMQ 3 due to change of x-ha-policy to ha-mode #4896

@joekohlsdorf

Description

@joekohlsdorf

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):

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions