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 3
def initialize(queue, job)
  super
  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 8
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 13
def requeue
  super
  acknowledge
end

Private Instance Methods

redis_retryable(&block) click to toggle source
# File lib/sidekiq/limit_fetch/unit_of_work.rb, line 20
def redis_retryable(&block)
  Sidekiq::LimitFetch.redis_retryable(&block)
end