diff --git a/hooks/rabbitmq_server_relations.py b/hooks/rabbitmq_server_relations.py index f712a8dd..1a7d7ab9 100755 --- a/hooks/rabbitmq_server_relations.py +++ b/hooks/rabbitmq_server_relations.py @@ -128,7 +128,8 @@ def amqp_changed(relation_id=None, remote_unit=None): relation_settings['rid'] = relation_id # set if need HA queues or not - relation_settings['ha_queues'] = (rabbit.compare_version('3.0.1') >= 0) + if rabbit.compare_version('3.0.1') >= 0: + relation_settings['ha_queues'] = True relation_set(relation_settings=relation_settings)