Class: Sidekiq::Cronitor::ServerMiddleware

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

Instance Method Summary collapse

Instance Method Details

#call(worker, message, queue) ⇒ Object



16
17
18
19
20
21
22
23
24
25
26
27
# File 'lib/sidekiq/cronitor.rb', line 16

def call(worker, message, queue)
  ping(worker: worker, state: 'run')

  result = yield
rescue => e
  ping(worker: worker, state: 'fail', message: e.to_s)

  raise e
else
  ping(worker: worker, state: 'complete')
  result # to be consistent with client middleware, return results of yield
end