Contents

# frozen_string_literal: true

module SidekiqUniqueJobs
  module Connection
    def self.included(base)
      base.send(:extend, self)
    end

    # :reek:UtilityFunction { enabled: false }
    def redis(redis_pool = nil)
      if redis_pool
        redis_pool.with { |conn| yield conn }
      else
        Sidekiq.redis { |conn| yield conn }
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
sidekiq-unique-jobs-6.0.0.rc6	lib/sidekiq_unique_jobs/connection.rb
sidekiq-unique-jobs-6.0.0.rc5	lib/sidekiq_unique_jobs/connection.rb
sidekiq-unique-jobs-6.0.0.rc4	lib/sidekiq_unique_jobs/connection.rb
sidekiq-unique-jobs-6.0.0.rc3	lib/sidekiq_unique_jobs/connection.rb
sidekiq-unique-jobs-6.0.0.rc2	lib/sidekiq_unique_jobs/connection.rb
sidekiq-unique-jobs-6.0.0.rc1	lib/sidekiq_unique_jobs/connection.rb