Vagrant/roles/ansible-rabbitmq/tasks/rabbitmq_clustering.yml

   1 ---
   2 - name: rabbitmq_clustering | stopping rabbitmq app
   3   command: rabbitmqctl stop_app
   4   when: inventory_hostname != "{{ rabbitmq_master }}"
   5
   6 - name: rabbitmq_clustering | resetting rabbitmq app
   7   command: rabbitmqctl reset
   8   when: inventory_hostname != "{{ rabbitmq_master }}"
   9
  10 - name: rabbitmq_clustering | stopping rabbitmq-server
  11   service:
  12     name: rabbitmq-server
  13     state: stopped
  14
  15 #- name: grabbing erlang cookie
  16 #  shell: cat /var/lib/rabbitmq/.erlang.cookie
  17 #  register: rabbitmq_erlang_cookie
  18 #  when: inventory_hostname == "{{ rabbitmq_master }}"
  19
  20 - name: rabbitmq_clustering | copy erlang cookie
  21   template:
  22     src: erlang.cookie.j2
  23     dest: "{{ rabbitmq_erlang_cookie_file }}"
  24     owner: rabbitmq
  25     group: rabbitmq
  26     mode: 0400
  27     backup: yes #backing up in case the need to recover
  28 #  when: inventory_hostname != "{{ rabbitmq_master }}"
  29
  30 - name: rabbitmq_clustering | restarting rabbitmq-server on master
  31   service:
  32     name: rabbitmq-server
  33     state: restarted
  34   when: inventory_hostname == "{{ rabbitmq_master }}"
  35
  36 - name: rabbitmq_clustering | starting rabbitmq app on master
  37   command: rabbitmqctl start_app
  38   register: cluster_master
  39   when: inventory_hostname == "{{ rabbitmq_master }}"
  40
  41 - name: rabbitmq_clustering | sending sigterm to any running rabbitmq processes
  42   shell: pkill -u rabbitmq || true
  43   when: inventory_hostname != "{{ rabbitmq_master }}"
  44
  45 - name: rabbitmq_clustering | restarting rabbitmq-server
  46   service:
  47     name: rabbitmq-server
  48     state: restarted
  49   when: inventory_hostname != "{{ rabbitmq_master }}"
  50
  51 - name: rabbitmq_clustering | stopping rabbitmq app
  52   command: rabbitmqctl stop_app
  53   when: inventory_hostname != "{{ rabbitmq_master }}"
  54
  55 - name: rabbitmq_clustering | resetting rabbitmq app
  56   command: rabbitmqctl reset
  57   when: inventory_hostname != "{{ rabbitmq_master }}"
  58
  59 - name: rabbitmq_clustering | joining rabbitmq cluster
  60   command: rabbitmqctl join_cluster "rabbit@{{ hostvars[rabbitmq_master]['ansible_hostname'] }}"
  61   register: cluster_joined
  62   when: inventory_hostname != "{{ rabbitmq_master }}"
  63
  64 - name: rabbitmq_clustering | starting rabbitmq app
  65   command: rabbitmqctl start_app
  66   when: inventory_hostname != "{{ rabbitmq_master }}"
  67
  68 - name: rabbitmq_clustering | marking as clustered
  69   file:
  70     path: /etc/rabbitmq/clustered
  71     state: touch
  72   when: cluster_master.changed or cluster_joined.changed