class RubyJob::JobProcessor

Public Class Methods

new(jobstore) click to toggle source
# File lib/ruby_job/job_processor.rb, line 5
def initialize(jobstore)
  @jobstore = jobstore
end

Public Instance Methods

run(**options) click to toggle source
# File lib/ruby_job/job_processor.rb, line 9
def run(**options)
  loop do
    job = @jobstore.set(**options).fetch
    job ? job.perform : break
  end
end