Class: Delayed::WorkQueue::InProcess

Inherits:
Object
  • Object
show all
Defined in:
lib/delayed/work_queue/in_process.rb

Overview

queries the queue inline.

Instance Method Summary collapse

Instance Method Details

#get_and_lock_next_available(worker_name, queue_name, min_priority, max_priority) ⇒ Object 



6
7
8
9
10
 
# File 'lib/delayed/work_queue/in_process.rb', line 6

def get_and_lock_next_available(worker_name, queue_name, min_priority, max_priority)
  Delayed::Worker.lifecycle.run_callbacks(:work_queue_pop, self) do
    Delayed::Job.get_and_lock_next_available(worker_name, queue_name, min_priority, max_priority)
  end
end