Hook method that is called after a new worker is forked
# File lib/delayed/backend/base.rb, line 54 def after_fork end
Hook method that is called before a new worker is forked
# File lib/delayed/backend/base.rb, line 50 def before_fork end
Add a job to the queue
# File lib/delayed/backend/base.rb, line 10 def enqueue(*args) options = { :priority => Delayed::Worker.default_priority }.merge!(args.extract_options!) options[:payload_object] ||= args.shift if args.size > 0 warn "[DEPRECATION] Passing multiple arguments to `#enqueue` is deprecated. Pass a hash with :priority and :run_at." options[:priority] = args.first || options[:priority] options[:run_at] = args[1] end unless options[:payload_object].respond_to?(:perform) raise ArgumentError, 'Cannot enqueue items which do not respond to perform' end if Delayed::Worker.delay_jobs self.new(options).tap do |job| Delayed::Worker.lifecycle.run_callbacks(:enqueue, job) do job.hook(:enqueue) job.save end end else Delayed::Job.new(:payload_object => options[:payload_object]).tap do |job| job.invoke_job end end end
# File lib/delayed/backend/base.rb, line 41 def reserve(worker, max_run_time = Worker.max_run_time) # We get up to 5 jobs from the db. In case we cannot get exclusive access to a job we try the next. # this leads to a more even distribution of jobs across the worker processes find_available(worker.name, 5, max_run_time).detect do |job| job.lock_exclusively!(max_run_time, worker.name) end end
Generated with the Darkfish Rdoc Generator 2.