Module: Resque

Defined in:
lib/resque/plugins/priority.rb

Defined Under Namespace

Modules: Plugins

Class Method Summary collapse

Class Method Details

.enqueue_with_priority(priority, klass, *args) ⇒ Object



2
3
4
5
6
7
8
9
10
# File 'lib/resque/plugins/priority.rb', line 2

def self.enqueue_with_priority(priority, klass, *args)
  queue = klass.instance_variable_get(:@queue) || (klass.respond_to?(:queue) and klass.queue)
  priority ||= :normal
  if [:high, :low].include?(priority.to_sym)
    queue = "#{queue}_#{priority}".to_sym
  end
  klass.priority = priority
  Resque::Job.create(queue, klass, *args)
end