]>
Commit | Line | Data |
---|---|---|
eb299d9b | 1 | --- |
93a297c5 LSJ |
2 | - name: rabbitmq_ha_config | checking if rabbitmqadmin is installed |
3 | stat: | |
4 | path: /usr/sbin/rabbitmqadmin | |
5 | register: rabbitmqadmin_check | |
6 | ||
a290f6cf | 7 | - name: rabbitmq_ha_config | install rabbitMQ admin |
93a297c5 LSJ |
8 | shell: wget http://guest:guest@localhost:15672/cli/rabbitmqadmin |
9 | when: not rabbitmqadmin_check.stat.exists | |
eb299d9b | 10 | |
a290f6cf | 11 | - name: rabbitmq_ha_config | moving the rabbitMQ Admin |
eb299d9b | 12 | shell: mv rabbitmqadmin /usr/sbin |
93a297c5 | 13 | when: not rabbitmqadmin_check.stat.exists |
eb299d9b | 14 | |
a290f6cf | 15 | - name: rabbitmq_ha_config | making executable rabbitMQ Admin |
eb299d9b LSJ |
16 | shell: chmod +x /usr/sbin/rabbitmqadmin |
17 | notify: restart rabbitmq-server | |
93a297c5 | 18 | when: not rabbitmqadmin_check.stat.exists |
eb299d9b | 19 | |
a290f6cf | 20 | - name: rabbitmq_ha_config | creating queue(s) |
d5d7b014 | 21 | command: rabbitmqadmin declare queue name={{ item.queue_name }} durable={{ item.durable|lower }} |
eb299d9b | 22 | run_once: true |
ba5539ac | 23 | with_items: "{{ rabbitmq_config }}" |
eb299d9b | 24 | |
a290f6cf | 25 | - name: rabbitmq_ha_config | setting up ha on queue(s) |
93a297c5 LSJ |
26 | rabbitmq_policy: |
27 | name: "ha-all" | |
28 | pattern: "{{ item.queue_name }}" | |
29 | tags: "{{ item.tags }}" | |
30 | state: present | |
eb299d9b | 31 | run_once: true |
ba5539ac | 32 | with_items: "{{ rabbitmq_config }}" |
eb299d9b | 33 | |
a290f6cf | 34 | - name: rabbitmq_ha_config | creating exchange(s) |
eb299d9b LSJ |
35 | command: rabbitmqadmin declare exchange name={{ item.exchange_name }} type={{ item.type }} |
36 | run_once: true | |
ba5539ac | 37 | with_items: "{{ rabbitmq_config }}" |
93a297c5 | 38 | when: item.exchange_name is defined |
eb299d9b | 39 | |
a290f6cf | 40 | - name: rabbitmq_ha_config | creating binding(s) |
eb299d9b LSJ |
41 | command: rabbitmqadmin declare binding source={{ item.exchange_name }} destination_type="queue" destination={{ item.queue_name }} routing_key={{ item.routing_key }} |
42 | run_once: true | |
ba5539ac | 43 | with_items: "{{ rabbitmq_config }}" |
93a297c5 | 44 | when: item.exchange_name is defined |