# File lib/nanite/cluster.rb, line 187 def setup_heartbeat_queue handler = lambda do |ping| begin ping = serializer.load(ping) Nanite::Log.debug("RECV #{ping.to_s}") if ping.respond_to?(:to_s) handle_ping(ping) rescue Exception => e Nanite::Log.error("RECV [ping] #{e.message}") end end hb_fanout = amq.fanout('heartbeat', :durable => true) if shared_state? amq.queue("heartbeat").bind(hb_fanout).subscribe &handler else amq.queue("heartbeat-#{identity}", :exclusive => true).bind(hb_fanout).subscribe &handler end end