Sha256: 8134c91eeb35e4606d1d4810d895c118cb93dc351be75206be27cbc7b8db14a6
Contents?: true
Size: 715 Bytes
Versions: 22
Compression:
Stored size: 715 Bytes
Contents
# frozen_string_literal: true
module SidekiqUniqueJobs
module Middleware
# The unique sidekiq middleware for the server processor
#
# @author Mikael Henriksson <mikael@zoolutions.se>
class Server
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(*)
lock_instance.execute { yield }
end
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems