class Sidekiq::LimitFetch::UnitOfWork

Public Class Methods

new(queue, job) click to toggle source
Calls superclass method
# File lib/sidekiq/limit_fetch/unit_of_work.rb, line 6
def initialize(queue, job)
  if post_6_5?
    super(queue, job, Sidekiq)
  else
    super
  end
  redis_retryable { Queue[queue_name].increase_busy }
end

Public Instance Methods

acknowledge() click to toggle source
# File lib/sidekiq/limit_fetch/unit_of_work.rb, line 15
def acknowledge
  redis_retryable { Queue[queue_name].decrease_busy }
  redis_retryable { Queue[queue_name].release }
end
requeue() click to toggle source
Calls superclass method
# File lib/sidekiq/limit_fetch/unit_of_work.rb, line 20
def requeue
  super
  acknowledge
end

Private Instance Methods

post_6_5?() click to toggle source
# File lib/sidekiq/limit_fetch/unit_of_work.rb, line 27
def post_6_5?
  Gem::Version.new(Sidekiq::VERSION) >= Gem::Version.new('6.5.0')
end
redis_retryable(&block) click to toggle source
# File lib/sidekiq/limit_fetch/unit_of_work.rb, line 31
def redis_retryable(&block)
  Sidekiq::LimitFetch.redis_retryable(&block)
end