class AlacrityRails::Probe::SidekiqServerMiddleware

Constants

ACTIVE_JOB_WRAPPER

Public Instance Methods

call(worker_instance, msg, queue) { || ... } click to toggle source
# File lib/alacrity-rails/probe/sidekiq.rb, line 6
def call(worker_instance, msg, queue)
  if ACTIVE_JOB_WRAPPER.match(msg['class'])
    yield
  else
    AlacrityRails::Instrumentor.instrument(
      type: AlacrityRails::Transaction::Job,
      data: {
        name: msg['class'],
        args: msg['args'],
        error_class: msg['error_class'],
        error_message: msg['error_message']
      }
    ) do
      yield
    end
  end
end