Class: Sidekiq::QueueMetrics::JobDeathMonitor

Inherits:
Monitor
  • Object
show all
Defined in:
lib/sidekiq_queue_metrics/monitor/job_death_monitor.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.proc ⇒ Object 



5
6
7
8
9
 
# File 'lib/sidekiq_queue_metrics/monitor/job_death_monitor.rb', line 5

def self.proc
  Proc.new do |job, exception|
    JobDeathMonitor.new.monitor(job)
  end
end

Instance Method Details

#monitor(job) ⇒ Object 



11
12
13
14
 
# File 'lib/sidekiq_queue_metrics/monitor/job_death_monitor.rb', line 11

def monitor(job)
  super(job['queue'])
  Storage.add_failed_job(job)
end

#status_counter ⇒ Object 



16
17
18
 
# File 'lib/sidekiq_queue_metrics/monitor/job_death_monitor.rb', line 16

def status_counter
  'failed'
end