diff options
Diffstat (limited to 'lib/yahns/queue_egg.rb')
-rw-r--r-- | lib/yahns/queue_egg.rb | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/lib/yahns/queue_egg.rb b/lib/yahns/queue_egg.rb index a2abc2f..dde72bf 100644 --- a/lib/yahns/queue_egg.rb +++ b/lib/yahns/queue_egg.rb @@ -4,20 +4,17 @@ # this represents a Yahns::Queue before its vivified. This only # lives in the parent process and should be clobbered after qc_vivify class Yahns::QueueEgg # :nodoc: - attr_writer :max_events, :worker_threads - attr_accessor :logger + attr_accessor :max_events, :worker_threads def initialize @max_events = 1 # 1 is good if worker_threads > 1 @worker_threads = 7 # any default is wrong for most apps... - @logger = nil end # only call after forking - def qc_vivify(fdmap) + def vivify(fdmap) queue = Yahns::Queue.new queue.fdmap = fdmap - queue.spawn_worker_threads(@logger, @worker_threads, @max_events) queue end end |