Class: Sidejobs::Processor

Inherits:
Object
  • Object
show all
Includes:
Loggable
Defined in:
lib/sidejobs/processor.rb

Instance Method Summary collapse

Instance Method Details

#process ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
 
# File 'lib/sidejobs/processor.rb', line 5

def process
  Sidejobs.queue.fetch.each do |job|
    job.update state: 'processing', processed_at: Time.zone.now, attempts: job.attempts+1
    begin
      ActiveJob::Base.execute job.data
      job.update state: 'complete'
    rescue => exception
      job.update state: 'failing', error: exception.message
    end
  end
end