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