# File lib/nanite/agent.rb, line 209 def setup_queue if amq.respond_to?(:prefetch) && @options.has_key?(:prefetch) amq.prefetch(@options[:prefetch]) end amq.queue(identity, :durable => true).subscribe(:ack => true) do |info, msg| begin info.ack receive(serializer.load(msg)) rescue Exception => e Nanite::Log.error("RECV #{e.message}") end end end