Class: Pliny::Sidekiq::Middleware::Client::Log

Inherits:
Object
  • Object
show all
Defined in:
lib/pliny/sidekiq/middleware/client/log.rb

Instance Method Summary collapse

Instance Method Details

#call(worker_class, msg, queue, redis_pool) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
14
15
16
 
# 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
end