# 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