Method: Qu::Delayed::Worker#work

Defined in:
lib/qu/delayed/worker.rb

#work(options = {:block => true}) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/qu/delayed/worker.rb', line 25

def work(options = {:block => true})
  loop do
    logger.debug { "Getting next delayed job" }

    if payload = Qu.backend.next_delayed_job
      return Qu.backend.enqueue(payload)
    end

    if options[:block]
      sleep poll_frequency
    else
      break
    end
  end
end