class Pliny::Sidekiq::Middleware::Client::Log

Public Instance Methods

call(worker_class, msg, queue, redis_pool) { || ... } click to toggle source
# File lib/pliny/sidekiq/middleware/client/log.rb, line 4
def call(worker_class, msg, queue, redis_pool)
  yield.tap do
    data = {
      sidekiq:  true,
      job:      msg['class'],
      job_id:   msg['jid'],
      enqueued: true
    }
    data[:enqueued_at] = Time.at(msg['enqueued_at']) if msg.has_key?('enqueued_at')

    Pliny.log(data)
  end