Merge pull request #48 from tchoi80/COOK-2828

Make clustering work

recipes/default.rb

@@ -94,6 +94,22 @@
   not_if { platform?('smartos') }
 end
 
+template "#{node['rabbitmq']['config_root']}/rabbitmq-env.conf" do
+  source 'rabbitmq-env.conf.erb'
+  owner 'root'
+  group 'root'
+  mode 00644
+  notifies :restart, "service[#{node['rabbitmq']['service_name']}]"
+end
+
+template "#{node['rabbitmq']['config_root']}/rabbitmq.config" do
+  source 'rabbitmq.config.erb'
+  owner 'root'
+  group 'root'
+  mode 00644
+  notifies :restart, "service[#{node['rabbitmq']['service_name']}]"
+end
+
 if File.exists?(node['rabbitmq']['erlang_cookie_path'])
   existing_erlang_key =  File.read(node['rabbitmq']['erlang_cookie_path'])
 else
@@ -103,6 +119,7 @@
 if node['rabbitmq']['cluster'] && (node['rabbitmq']['erlang_cookie'] != existing_erlang_key)
   service "stop #{node['rabbitmq']['service_name']}" do
     service_name node['rabbitmq']['service_name']
+    pattern node['rabbitmq']['service_name']
     action :stop
   end
 
@@ -112,22 +129,13 @@
     group 'rabbitmq'
     mode 00400
     notifies :start, "service[#{node['rabbitmq']['service_name']}]", :immediately
+    notifies :run, "execute[reset-node]", :immediately
   end
 
+  # Need to reset for clustering #
+  execute "reset-node" do
+    command "rabbitmqctl stop_app && rabbitmqctl reset && rabbitmqctl start_app"
+    action :nothing
+  end
 end
 
-template "#{node['rabbitmq']['config_root']}/rabbitmq-env.conf" do
-  source 'rabbitmq-env.conf.erb'
-  owner 'root'
-  group 'root'
-  mode 00644
-  notifies :restart, "service[#{node['rabbitmq']['service_name']}]"
-end
-
-template "#{node['rabbitmq']['config_root']}/rabbitmq.config" do
-  source 'rabbitmq.config.erb'
-  owner 'root'
-  group 'root'
-  mode 00644
-  notifies :restart, "service[#{node['rabbitmq']['service_name']}]"
-end