Class: RailsPerformance::Gems::Sidekiq

Inherits:
Object
  • Object
show all
Defined in:
lib/rails_performance/gems/sidekiq.rb

Instance Method Summary collapse

Constructor Details

#initialize(options = nil) ⇒ Sidekiq

Returns a new instance of Sidekiq.



5
6
 
# File 'lib/rails_performance/gems/sidekiq.rb', line 5

def initialize(options=nil)
end

Instance Method Details

#call(worker, msg, queue) ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/rails_performance/gems/sidekiq.rb', line 8

def call(worker, msg, queue)
  now  = Time.now
  data = {
    enqueued_ati: msg['enqueued_at'].to_i,
    created_ati: msg['created_at'].to_i,
    jid: msg['jid'],
    queue: queue,
    start_timei: now.to_i,
    datetime: now.strftime(RailsPerformance::FORMAT),
    worker: msg['wrapped'.freeze] || worker.class.to_s
  }
  begin
    yield
    data[:status]   = "success"
  rescue Exception => ex
    data[:status]   = "exception"
    data[:message]  = ex.message
  ensure
    # store in ms instead of seconds
    data[:duration] = (Time.now - now) * 1000
    #puts data
    RailsPerformance::Utils.log_job_in_redis(data)
  end
end