Sha256: 1207d67e8d499a98df4d364abb7147d9757e7c619071b8a713e1070dc42c0980

Contents?: true

Size: 654 Bytes

Versions: 9

Compression:

Stored size: 654 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 strategy
        @strategy ||= OnConflict.find_strategy(:reject).new(item)
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
sidekiq-unique-jobs-6.0.25 lib/sidekiq_unique_jobs/lock/while_executing_reject.rb
sidekiq-unique-jobs-6.0.24 lib/sidekiq_unique_jobs/lock/while_executing_reject.rb
sidekiq-unique-jobs-6.0.23 lib/sidekiq_unique_jobs/lock/while_executing_reject.rb
sidekiq-unique-jobs-6.0.22 lib/sidekiq_unique_jobs/lock/while_executing_reject.rb
sidekiq-unique-jobs-6.0.21 lib/sidekiq_unique_jobs/lock/while_executing_reject.rb
sidekiq-unique-jobs-6.0.20 lib/sidekiq_unique_jobs/lock/while_executing_reject.rb
sidekiq-unique-jobs-6.0.16 lib/sidekiq_unique_jobs/lock/while_executing_reject.rb
sidekiq-unique-jobs-6.0.19 lib/sidekiq_unique_jobs/lock/while_executing_reject.rb
sidekiq-unique-jobs-6.0.13 lib/sidekiq_unique_jobs/lock/while_executing_reject.rb