Method: EQ::Queueing::Backends::Sequel#iterator

Defined in:
lib/eq-queueing/backends/sequel.rb

#iterator ⇒ Object 



116
117
118
119
120
121
 
# File 'lib/eq-queueing/backends/sequel.rb', line 116

def iterator
  jobs.each do |job|
    job[:payload] = Marshal.load(job[:payload]) if job[:payload]
    yield job
  end
end