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 | copy erlang cookie
   9   template: src=erlang.cookie.j2 dest=/var/lib/rabbitmq/.erlang.cookie owner=rabbitmq group=rabbitmq mode=0400 backup=yes
  10
  11 - name: rabbitmq_clustering | starting rabbitmq app
  12   command: rabbitmqctl start_app
  13   register: cluster_master
  14   when: master_rabbit_node is defined and master_rabbit_node
  15
  16 - name: rabbitmq_clustering | sending sigterm to any running rabbitmq processes
  17   shell: pkill -u rabbitmq || true
  18   when: (master_rabbit_node is defined and not master_rabbit_node) and cluster_master.changed
  19
  20 - name: rabbitmq_clustering | restarting rabbitmq-server
  21   service: name=rabbitmq-server state=restarted
  22   when: (master_rabbit_node is defined and not master_rabbit_node) and cluster_master.changed
  23
  24 - name: rabbitmq_clustering | stopping rabbitmq app
  25   command: rabbitmqctl stop_app
  26   when: (master_rabbit_node is defined and not master_rabbit_node) and cluster_master.changed
  27
  28 - name: rabbitmq_clustering | resetting rabbitmq app
  29   command: rabbitmqctl reset
  30   when: (master_rabbit_node is defined and not master_rabbit_node) and cluster_master.changed
  31
  32 - name: rabbitmq_clustering | joining rabbitmq cluster
  33   command: rabbitmqctl join_cluster 'rabbit@{{ master_rabbit_node }}'
  34   when: (master_rabbit_node is defined and not master_rabbit_node) and cluster_master.changed
  35
  36 - name: rabbitmq_clustering | starting rabbitmq app
  37   command: rabbitmqctl start_app
  38   when: (master_rabbit_node is defined and not master_rabbit_node) and cluster_master.changed
  39
  40 - name: rabbitmq_clustering | marking as clustered
  41   file: path=/etc/rabbitmq/clustered state=touch
  42   when: cluster_master.changed