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