Contents

require_relative 'monitor'

module Sidekiq::QueueMetrics
  class JobSuccessMonitor < Monitor
    def call(worker, job, queue)
      yield if block_given?
      monitor(queue)
    end

    def status_counter
      'processed'
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq_queue_metrics-3.0.0	lib/sidekiq_queue_metrics/monitor/job_success_monitor.rb