Contents

require_relative 'monitor'

module Sidekiq::QueueMetrics
  class JobDeathMonitor < Monitor
    def self.proc
      Proc.new do |job, exception|
        queue = job['queue']
        JobDeathMonitor.new.monitor(queue)
      end
    end

    def status_counter
      'failed'
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sidekiq_queue_metrics-1.0	lib/sidekiq_queue_metrics/monitor/job_death_monitor.rb
sidekiq_queue_metrics-0.0.4	lib/sidekiq_queue_metrics/monitor/job_death_monitor.rb
sidekiq_queue_metrics-0.0.3	lib/sidekiq_queue_metrics/monitor/job_death_monitor.rb
sidekiq_queue_metrics-0.0.2	lib/sidekiq_queue_metrics/monitor/job_death_monitor.rb