]>
Commit | Line | Data |
---|---|---|
109c6b75 LSJ |
1 | --- |
2 | - name: rabbitmq_ha_config | checking if rabbitmqadmin is installed | |
3 | stat: | |
4 | path: /usr/sbin/rabbitmqadmin | |
5 | register: rabbitmqadmin_check | |
6 | ||
9cac3978 LSJ |
7 | - name: rabbit_ha_config | Installing rabbitMQ admin |
8 | get_url: | |
9 | url: http://guest:guest@localhost:15672/cli/rabbitmqadmin | |
10 | dest: /usr/sbin/rabbitmqadmin | |
11 | mode: u=rwx,g=rw,o=rw | |
a67dde50 | 12 | become: true |
9cac3978 | 13 | notify: restart rabbitmq-server |
a67dde50 | 14 | when: not rabbitmqadmin_check['stat']['exists'] |
109c6b75 | 15 | |
109c6b75 | 16 | - name: rabbitmq_ha_config | creating queue(s) |
a67dde50 | 17 | command: rabbitmqadmin declare queue name={{ item['queue_name'] }} durable={{ item['durable']|lower }} |
109c6b75 | 18 | run_once: true |
a67dde50 | 19 | become: true |
109c6b75 LSJ |
20 | with_items: "{{ rabbitmq_config }}" |
21 | ||
22 | - name: rabbitmq_ha_config | setting up ha on queue(s) | |
23 | rabbitmq_policy: | |
613299cd | 24 | name: ha-all |
a67dde50 LSJ |
25 | pattern: "{{ item['queue_name'] }}" |
26 | tags: "{{ item['tags'] }}" | |
109c6b75 LSJ |
27 | state: present |
28 | run_once: true | |
a67dde50 | 29 | become: true |
109c6b75 LSJ |
30 | with_items: "{{ rabbitmq_config }}" |
31 | ||
32 | - name: rabbitmq_ha_config | creating exchange(s) | |
a67dde50 | 33 | command: rabbitmqadmin declare exchange name={{ item['exchange_name'] }} type={{ item['type'] }} |
109c6b75 | 34 | run_once: true |
a67dde50 | 35 | become: true |
109c6b75 | 36 | with_items: "{{ rabbitmq_config }}" |
a67dde50 | 37 | when: item['exchange_name'] is defined |
109c6b75 LSJ |
38 | |
39 | - name: rabbitmq_ha_config | creating binding(s) | |
a67dde50 | 40 | command: rabbitmqadmin declare binding source={{ item['exchange_name'] }} destination_type="queue" destination={{ item['queue_name'] }} routing_key={{ item['routing_key'] }} |
109c6b75 | 41 | run_once: true |
a67dde50 | 42 | become: true |
109c6b75 | 43 | with_items: "{{ rabbitmq_config }}" |
a67dde50 | 44 | when: item['exchange_name'] is defined |