Class: Delayed::Command
- Inherits:
-
Object
- Object
- Delayed::Command
- Defined in:
- lib/delayed/command.rb
Instance Method Summary collapse
- #daemonize ⇒ Object
-
#initialize(args) ⇒ Command
constructor
A new instance of Command.
- #logger ⇒ Object
- #run(worker_name = nil) ⇒ Object
Constructor Details
#initialize(args) ⇒ Command
Returns a new instance of Command.
7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 |
# File 'lib/delayed/command.rb', line 7 def initialize(args) @files_to_reopen = [] @options = {:quiet => true, :worker_count => 1} opts = OptionParser.new do |opts| opts. = "Usage: #{File.basename($0)} [options] start|stop|restart|run" opts.on('-h', '--help', 'Show this message') do puts opts exit 1 end opts.on('-e', '--environment=NAME', 'Specifies the environment to run this delayed jobs under (test/development/production).') do |e| 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" end opts.on('--min-priority N', 'Minimum priority of jobs to run.') do |n| @options[:min_priority] = n end opts.on('--max-priority N', 'Maximum priority of jobs to run.') do |n| @options[:max_priority] = n end opts.on('-n', '--number_of_workers=workers', "Number of unique workers to spawn") do |worker_count| begin @options[:worker_count] = worker_count.to_i if worker_count.to_i > 0 rescue end end end @args = opts.parse!(args) end |
Instance Method Details
#daemonize ⇒ Object
37 38 39 40 41 42 43 44 45 46 |
# File 'lib/delayed/command.rb', line 37 def daemonize ObjectSpace.each_object(File) do |file| @files_to_reopen << file unless file.closed? end process_name = 'delayed_job' Daemons.run_proc(process_name, :dir => "#{RAILS_ROOT}/tmp/pids", :dir_mode => :normal, :ARGV => @args) do |*args| run process_name end end |
#logger ⇒ Object
48 49 50 51 52 53 54 55 56 |
# File 'lib/delayed/command.rb', line 48 def logger if defined?(Rails) && Rails.respond_to?(:logger) Rails.logger elsif defined?(RAILS_DEFAULT_LOGGER) RAILS_DEFAULT_LOGGER elsif defined?(Merb) && Merb.respond_to?(:logger) Merb.logger end end |
#run(worker_name = nil) ⇒ Object
58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 |
# File 'lib/delayed/command.rb', line 58 def run(worker_name = nil) Dir.chdir(RAILS_ROOT) # Re-open file handles @files_to_reopen.each do |file| begin file.reopen File.join(RAILS_ROOT, 'log', 'delayed_job.log'), 'a+' file.sync = true rescue ::Exception end end Delayed::Worker.logger = logger if logger ActiveRecord::Base.connection.reconnect! worker = Delayed::Worker.new(@options) worker.name_prefix = "#{worker_name} " worker.start rescue => e logger.fatal e if logger STDERR.puts e. exit 1 end |