def joined_cluster?(node_name, cluster_status)
 Chef::Log.warn(cluster_status.to_s)
 Chef::Log.warn(node_name)
 (running_nodes(cluster_status) || '').include?(node_name)
end

# Match regex pattern from result of rabbitmqctl cluster_status
def match_pattern_cluster_status(cluster_status, pattern)
  if cluster_status.nil? || cluster_status.to_s.empty?
    Chef::Application.fatal!('[rabbitmq_cluster] cluster_status should not be empty')
  end
  match = cluster_status.match(pattern)
  match && match[2]
end

# Get running nodes
def running_nodes(cluster_status)
  pattern = '({running_nodes,\[\'*)(.*?)(\'*\]})'
  match = match_pattern_cluster_status(cluster_status, pattern)
  result = match && match.delete("'")
  Chef::Log.warn("[rabbitmq_cluster] running_nodes : #{result}")
  result.nil? ? [] : result
end

var_cluster_status = cluster_status
var_node_name = node_name
var_running_nodes = running_nodes(var_cluster_status)

Chef::Log.warn(joined_cluster?(var_cluster_status,var_node_name).to_s)