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

#closeObject

intentional nops for compatibility w/ parent process



17
# File 'lib/delayed/work_queue/in_process.rb', line 17

def close; end

#get_and_lock_next_available(worker_name, worker_config) ⇒ Object



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

def get_and_lock_next_available(worker_name, worker_config)
  Delayed::Worker.lifecycle.run_callbacks(:work_queue_pop, self, worker_config) do
    Delayed::Job.get_and_lock_next_available(
      worker_name,
      worker_config[:queue],
      worker_config[:min_priority],
      worker_config[:max_priority])
  end
end

#wake_upObject



18
# File 'lib/delayed/work_queue/in_process.rb', line 18

def wake_up; end