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