class Sidekiq::JobMonitor::Middleware

Public Instance Methods

call(worker, msg, queue) { || ... } click to toggle source

Wrap Sidekiq default job execution with completion and failure handling to make previous jobs tracking easy

# File lib/sidekiq/job_monitor/middleware.rb, line 6
def call(worker, msg, queue)
  job = Sidekiq::JobMonitor::Job.new(msg)

  job.processing!

  begin
    yield
    job.complete!
  rescue
    job.failed!
    raise
  end
end