Class: Sidekiq::Throttled::Middlewares::Server

Inherits:
Object
  • Object
show all
Includes:
ServerMiddleware
Defined in:
lib/sidekiq/throttled/middlewares/server.rb

Overview

Server middleware required for Sidekiq::Throttled functioning.

Instance Method Summary collapse

Instance Method Details

#call(_worker, msg, _queue) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/sidekiq/throttled/middlewares/server.rb', line 13

def call(_worker, msg, _queue)
  yield
ensure
  job = msg.fetch("wrapped") { msg["class"] }
  jid = msg["jid"]

  if job && jid
    Registry.get job do |strategy|
      strategy.finalize!(jid, *msg["args"])
    end
  end
end