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