Module: Delayed::Backend::Base::ClassMethods

Defined in:
lib/delayed/backend/base.rb

Instance Method Summary collapse

Instance Method Details

#after_fork ⇒ Object

Hook method that is called after a new worker is forked



29
30
 
# File 'lib/delayed/backend/base.rb', line 29

def after_fork
end

#before_fork ⇒ Object

Hook method that is called before a new worker is forked



25
26
 
# File 'lib/delayed/backend/base.rb', line 25

def before_fork
end

#enqueue(*args) ⇒ Object

Add a job to the queue



13
14
15
16
17
18
19
20
21
22
 
# File 'lib/delayed/backend/base.rb', line 13

def enqueue(*args)
  object = args.shift
  unless object.respond_to?(:perform)
    raise ArgumentError, 'Cannot enqueue items which do not respond to perform'
  end
    
  priority = args.first || 0
  run_at   = args[1]
  self.create(:payload_object => object, :priority => priority.to_i, :run_at => run_at)
end

#work_off(num = 100) ⇒ Object 



32
33
34
35
 
# File 'lib/delayed/backend/base.rb', line 32

def work_off(num = 100)
  warn "[DEPRECATION] `Delayed::Job.work_off` is deprecated. Use `Delayed::Worker.new.work_off instead."
  Delayed::Worker.new.work_off(num)
end