class Sidekiq::QueueMetrics::JobDeathMiddleware

Public Instance Methods

call(worker, msg, queue) { || ... } click to toggle source
# File lib/sidekiq_queue_metrics/job_death_middleware.rb, line 3
def call(worker, msg, queue)
  call_dead_monitor(msg) if is_dead_job?(msg)

  yield if block_given?
end
call_dead_monitor(msg) click to toggle source
# File lib/sidekiq_queue_metrics/job_death_middleware.rb, line 13
def call_dead_monitor(msg)
  Sidekiq::QueueMetrics::JobDeathMonitor.proc.call(msg, msg['error_class'])
end
is_dead_job?(msg) click to toggle source
# File lib/sidekiq_queue_metrics/job_death_middleware.rb, line 9
def is_dead_job?(msg)
  msg.key?('retry_count') && msg['retry_count'] == 0
end