Module: Qe::Worker::ClassMethods

Defined in:
lib/qe/worker/class_methods.rb

Instance Method Summary collapse

Instance Method Details

#enqueue(options = {}) ⇒ Object

Enqueue job on given worker class.



5
6
7
8
9
10
11
12
13
 
# File 'lib/qe/worker/class_methods.rb', line 5

def enqueue(options = {})
  run_at = options.delete(:run_at)

  if run_at
    Qe.adapter.schedule(self, run_at, options)
  else
    Qe.adapter.enqueue(self, options)
  end
end

#queue(*args) ⇒ Object

Set the queue name when receiving on argument. Return queue name otherwise.



17
18
19
20
 
# File 'lib/qe/worker/class_methods.rb', line 17

def queue(*args)
  @queue = args.first unless args.empty?
  (@queue || :default).to_s
end