class Sidekiq::Slog::ClientMiddleware

Public Instance Methods

call(worker_class, msg, queue, _redis_pool) { || ... } click to toggle source
# File lib/sidekiq-slog/middleware.rb, line 36
def call(worker_class, msg, queue, _redis_pool)
  context = {
    queue: queue,
    job_class: Sidekiq::Slog.job_class(msg),
    job_id: Sidekiq::Slog.job_id(msg)
  }
  if at = msg['at']
    context[:scheduled_at] = Time.at(at).utc
    SLog.log('job_schedule', context)
  else
    context[:args] = Sidekiq::Slog.job_args(msg)
    SLog.log('job_enqueue', context)
  end
  yield
end