class SidekiqHero::ServerMiddleware

Attributes

recorder[R]

Public Class Methods

new() click to toggle source
# File lib/sidekiq_hero/server_middleware.rb, line 7
def initialize
  @recorder = SidekiqHero::Recorder.new
end

Public Instance Methods

call(_worker, job, _queue) { || ... } click to toggle source
# File lib/sidekiq_hero/server_middleware.rb, line 11
def call(_worker, job, _queue)
  recorder.worker_passed
  yield
  recorder.worker_succeeded
rescue => e
  recorder.worker_failed(e)

  raise e
ensure
  recorder.worker_ended
  recorder.elapsed_time
  NotifierWrapper.new(job: job, meta_data: recorder.meta_data).call
end