Class: CanvasSync::JobUniqueness::Compat::Sidekiq::ServerMiddleware

Inherits:
CommonMiddleware
  • Object
show all
Includes:
Sidekiq::ServerMiddleware
Defined in:
lib/canvas_sync/job_uniqueness/compat/sidekiq.rb

Instance Method Summary collapse

Methods inherited from CommonMiddleware

#lock_context, #worker_uniqueness

Instance Method Details

#call(_worker, msg, _queue, &blk) ⇒ Object 



69
70
71
72
73
 
# File 'lib/canvas_sync/job_uniqueness/compat/sidekiq.rb', line 69

def call(_worker, msg, _queue, &blk)
  ctx = lock_context(msg)
  return blk.call unless ctx
  ctx.handle_lifecycle!(:perform, &blk)
end