Module: Resque

Extended by:: Resque

Included in:: Resque

Defined in:: lib/base/job/async_job.rb

Instance Method Summary collapse

#enqueue(klass, *args) ⇒ Object

Patch Resque so we can determine queue by input args.

Instance Method Details

#enqueue(klass, *args) ⇒ `Object`

Patch Resque so we can determine queue by input args. Job class can define select_queue method and the result will be the queue name.

# File 'lib/base/job/async_job.rb', line 13

def enqueue(klass, *args)
  queue = (klass.respond_to?(:select_queue) && klass.select_queue(*args)) || queue_from_class(klass)
  enqueue_to(queue, klass, *args)
end