diff --git a/tasks/mq_setup.yml b/tasks/mq_setup.yml index b8f9e45..5426136 100644 --- a/tasks/mq_setup.yml +++ b/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 }}"