tasks/rabbitmq_clustering.yml

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