Class Delayed::Command
In: lib/delayed/command.rb
Parent: Object

Methods

daemonize   new   run   run_process  

Attributes

worker_count  [RW] 

Public Class methods

[Source]

    # File lib/delayed/command.rb, line 9
 9:     def initialize(args)
10:       @files_to_reopen = []
11:       @options = {
12:         :quiet => true,
13:         :pid_dir => "#{RAILS_ROOT}/tmp/pids"
14:       }
15:       
16:       @worker_count = 1
17:       @monitor = false
18:       
19:       opts = OptionParser.new do |opts|
20:         opts.banner = "Usage: #{File.basename($0)} [options] start|stop|restart|run"
21: 
22:         opts.on('-h', '--help', 'Show this message') do
23:           puts opts
24:           exit 1
25:         end
26:         opts.on('-e', '--environment=NAME', 'Specifies the environment to run this delayed jobs under (test/development/production).') do |e|
27:           STDERR.puts "The -e/--environment option has been deprecated and has no effect. Use RAILS_ENV and see http://github.com/collectiveidea/delayed_job/issues/#issue/7"
28:         end
29:         opts.on('--min-priority N', 'Minimum priority of jobs to run.') do |n|
30:           @options[:min_priority] = n
31:         end
32:         opts.on('--max-priority N', 'Maximum priority of jobs to run.') do |n|
33:           @options[:max_priority] = n
34:         end
35:         opts.on('-n', '--number_of_workers=workers', "Number of unique workers to spawn") do |worker_count|
36:           @worker_count = worker_count.to_i rescue 1
37:         end
38:         opts.on('--pid-dir=DIR', 'Specifies an alternate directory in which to store the process ids.') do |dir|
39:           @options[:pid_dir] = dir
40:         end
41:         opts.on('-i', '--identifier=n', 'A numeric identifier for the worker.') do |n|
42:           @options[:identifier] = n
43:         end
44:         opts.on('-m', '--monitor', 'Start monitor process.') do
45:           @monitor = true
46:         end
47:         opts.on('--sleep-delay N', "Amount of time to sleep when no jobs are found") do |n|
48:           @options[:sleep_delay] = n
49:         end
50:       end
51:       @args = opts.parse!(args)
52:     end

Public Instance methods

[Source]

    # File lib/delayed/command.rb, line 54
54:     def daemonize
55:       Delayed::Worker.backend.before_fork
56: 
57:       ObjectSpace.each_object(File) do |file|
58:         @files_to_reopen << file unless file.closed?
59:       end
60:       
61:       dir = @options[:pid_dir]
62:       Dir.mkdir(dir) unless File.exists?(dir)
63:       
64:       if @worker_count > 1 && @options[:identifier]
65:         raise ArgumentError, 'Cannot specify both --number-of-workers and --identifier'
66:       elsif @worker_count == 1 && @options[:identifier]
67:         process_name = "delayed_job.#{@options[:identifier]}"
68:         run_process(process_name, dir)
69:       else
70:         worker_count.times do |worker_index|
71:           process_name = worker_count == 1 ? "delayed_job" : "delayed_job.#{worker_index}"
72:           run_process(process_name, dir)
73:         end
74:       end
75:     end

[Source]

     # File lib/delayed/command.rb, line 83
 83:     def run(worker_name = nil)
 84:       Dir.chdir(RAILS_ROOT)
 85:       
 86:       # Re-open file handles
 87:       @files_to_reopen.each do |file|
 88:         begin
 89:           file.reopen file.path, "a+"
 90:           file.sync = true
 91:         rescue ::Exception
 92:         end
 93:       end
 94:       
 95:       Delayed::Worker.logger = Logger.new(File.join(RAILS_ROOT, 'log', 'delayed_job.log'))
 96:       Delayed::Worker.backend.after_fork
 97:       
 98:       worker = Delayed::Worker.new(@options)
 99:       worker.name_prefix = "#{worker_name} "
100:       worker.start
101:     rescue => e
102:       Rails.logger.fatal e
103:       STDERR.puts e.message
104:       exit 1
105:     end

[Source]

    # File lib/delayed/command.rb, line 77
77:     def run_process(process_name, dir)
78:       Daemons.run_proc(process_name, :dir => dir, :dir_mode => :normal, :monitor => @monitor, :ARGV => @args) do |*args|
79:         run process_name
80:       end
81:     end

[Validate]