# 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