Sha256: c75276ed54ce800faa7662d7bef91be46da5545d2c928de048594720feda5ac3
Contents?: true
Size: 478 Bytes
Versions: 18
Compression:
Stored size: 478 Bytes
Contents
# frozen_string_literal: true
# internal
require "sidekiq/throttled/registry"
module Sidekiq
module Throttled
# Server middleware that notifies strategy that job was finished.
#
# @private
class Middleware
# Called within Sidekiq job processing
def call(_worker, msg, _queue)
yield
ensure
Registry.get msg["class"] do |strategy|
strategy.finalize!(msg["jid"], *msg["args"])
end
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems