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