class Sidekiq::Throttled::Middlewares::Server
Server
middleware required for Sidekiq::Throttled
functioning.
Public Instance Methods
Source
# File lib/sidekiq/throttled/middlewares/server.rb, line 14 def call(_worker, msg, _queue) yield ensure message = Message.new(msg) if message.job_class && message.job_id Registry.get(message.job_class) do |strategy| strategy.finalize!(message.job_id, *message.job_args) end end end