# File lib/nanite/cluster.rb, line 205
    def setup_registration_queue
      handler = lambda do |msg|
        begin
          register(serializer.load(msg))
        rescue Exception => e
          Nanite::Log.error("RECV [register] #{e.message}")
        end
      end
      reg_fanout = amq.fanout('registration', :durable => true)
      if shared_state?
        amq.queue("registration").bind(reg_fanout).subscribe &handler
      else
        amq.queue("registration-#{identity}", :exclusive => true).bind(reg_fanout).subscribe &handler
      end
    end