Sha256: d830f4441d54abd826f4648f80a4284d1443e318b9e9a10985846cd5258fa26f
Contents?: true
Size: 904 Bytes
Versions: 1
Compression:
Stored size: 904 Bytes
Contents
# frozen_string_literal: true module SidekiqUniqueJobs module Middleware # The unique sidekiq middleware for the server processor # # @author Mikael Henriksson <mikael@mhenrixon.com> class Server include Sidekiq::ClientMiddleware if defined?(Sidekiq::ServerMiddleware) # prepend "SidekiqUniqueJobs::Middleware" # @!parse prepends SidekiqUniqueJobs::Middleware prepend SidekiqUniqueJobs::Middleware # # # Runs the server middleware (used from Sidekiq::Processor#process) # # @see SidekiqUniqueJobs::Middleware#call # # @see https://github.com/mperham/sidekiq/wiki/Job-Format # @see https://github.com/mperham/sidekiq/wiki/Middleware # # @yield when uniqueness is disabled # @yield when owning the lock def call(*, &block) lock_instance.execute(&block) end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
sidekiq-unique-jobs-7.1.24 | lib/sidekiq_unique_jobs/middleware/server.rb |