diff --git a/sync/tasks/mq_setup.yml b/sync/tasks/mq_setup.yml index b8f9e453..5426136a 100644 --- a/sync/tasks/mq_setup.yml +++ b/sync/tasks/mq_setup.yml @@ -33,6 +33,16 @@ name: "{{ _oslomsg_rpc_vhost }}" state: "present" + - name: Apply RPC RabbitMQ vhost policies + rabbitmq_policy: + node: "rabbit@{{ _oslomsg_rpc_setup_host }}" + name: "{{ item.name }}" + pattern: "{{ item.pattern }}" + priority: "{{ item.priority | default(0) }}" + tags: "{{ item.tags }}" + vhost: "{{ _oslomsg_rpc_vhost }}" + loop: "{{ _oslomsg_rpc_policies | default([]) + oslomsg_rpc_policies }}" + - name: Add RPC RabbitMQ user rabbitmq_user: user: "{{ _oslomsg_rpc_userid }}" @@ -60,6 +70,18 @@ when: - _oslomsg_notify_vhost != _oslomsg_rpc_vhost + - name: Apply Notify RabbitMQ vhost policies + rabbitmq_policy: + node: "rabbit@{{ _oslomsg_notify_setup_host }}" + name: "{{ item.name }}" + pattern: "{{ item.pattern }}" + priority: "{{ item.priority | default(0) }}" + tags: "{{ item.tags }}" + vhost: "{{ _oslomsg_notify_vhost }}" + loop: "{{ _oslomsg_notify_policies | default([]) + oslomsg_notify_policies }}" + when: + - _oslomsg_notify_vhost != _oslomsg_rpc_vhost + - name: Add Notify RabbitMQ user rabbitmq_user: user: "{{ _oslomsg_notify_userid }}" diff --git a/test-vars.yml b/test-vars.yml index be5e486a..282c7bae 100644 --- a/test-vars.yml +++ b/test-vars.yml @@ -98,6 +98,11 @@ oslomsg_rpc_servers: "{{ rabbitmq_servers }}" oslomsg_rpc_use_ssl: "{{ rabbitmq_use_ssl }}" oslomsg_rpc_host_group: "{{ test_rabbitmq_group }}" oslomsg_rpc_password: "{{ rabbitmq_password }}" +oslomsg_rpc_policies: + - name: "HA" + pattern: '^(?!(amq\.)|(.*_fanout_)|(reply_)).*' + priority: 0 + tags: "ha-mode=all" # Oslo Messaging Notify Settings oslomsg_notify_transport: rabbit @@ -106,6 +111,11 @@ oslomsg_notify_servers: "{{ rabbitmq_servers }}" oslomsg_notify_use_ssl: "{{ rabbitmq_use_ssl }}" oslomsg_notify_host_group: "{{ test_rabbitmq_group }}" oslomsg_notify_password: "{{ rabbitmq_password }}" +oslomsg_notify_policies: + - name: "HA" + pattern: '^(?!(amq\.)|(.*_fanout_)|(reply_)).*' + priority: 0 + tags: "ha-mode=all" # Memcache Settings memcached_listen: "{{ test_memcached_host }}"