# File lib/nanite/nanite_dispatcher.rb, line 6 def initialize(amq, registry, serializer, identity, options) @amq = amq @registry = registry @serializer = serializer @identity = identity @options = options @evmclass = EM @evmclass.threadpool_size = (@options[:threadpool_size] || 20).to_i end