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