class DelayedJobCelluloid::Launcher
Attributes
manager[R]
options[R]
Public Class Methods
new(options, worker_count)
click to toggle source
# File lib/delayed_job_celluloid/launcher.rb, line 6 def initialize(options, worker_count) @options = options @manager = Manager.new(options, worker_count) end
Public Instance Methods
run()
click to toggle source
# File lib/delayed_job_celluloid/launcher.rb, line 11 def run DelayedJobCelluloid.logger.info 'Launching delayed_job_celluloid' manager.async.start end
stop()
click to toggle source
# File lib/delayed_job_celluloid/launcher.rb, line 16 def stop manager.async.stop(options[:timeout]) manager.wait(:shutdown) end