Class: Sidekiq::QueueMetrics::JobDeathMiddleware

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq_queue_metrics/job_death_middleware.rb

Instance Method Summary collapse

Instance Method Details

#call(worker, msg, queue) ⇒ Object 



3
4
5
6
7
 
# 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) ⇒ Object 



13
14
15
 
# 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) ⇒ Boolean

Returns:

  • (Boolean) 


9
10
11
 
# 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