# 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