Sha256: c5f34799d5fed593dcf947e7abafd00368bb3ef8a44928923adf098066ed826f
Contents?: true
Size: 680 Bytes
Versions: 18
Compression:
Stored size: 680 Bytes
Contents
# frozen_string_literal: true
module SidekiqUniqueJobs
class Lock
# Locks jobs while executing
# Locks from the server process
# Unlocks after the server is done processing
#
# See {#lock} for more information about the client.
# See {#execute} for more information about the server
#
# @author Mikael Henriksson <mikael@zoolutions.se>
class WhileExecutingReject < WhileExecuting
# Overridden with a forced {OnConflict::Reject} strategy
# @return [OnConflict::Reject] a reject strategy
def server_strategy
@server_strategy ||= OnConflict.find_strategy(:reject).new(item, redis_pool)
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems