Class: Sidekiq::LimitFetch::UnitOfWork

Inherits:
BasicFetch::UnitOfWork
  • Object
show all
Defined in:
lib/sidekiq/limit_fetch/unit_of_work.rb

Instance Method Summary collapse

Constructor Details

#initialize(queue, job) ⇒ UnitOfWork

Returns a new instance of UnitOfWork.



3
4
5
6
7
8
9
10
 
# File 'lib/sidekiq/limit_fetch/unit_of_work.rb', line 3

def initialize(queue, job)
  if post_6_5?
    super(queue, job, Sidekiq)
  else
    super
  end
  redis_retryable { Queue[queue_name].increase_busy }
end

Instance Method Details

#acknowledge ⇒ Object 



12
13
14
15
 
# File 'lib/sidekiq/limit_fetch/unit_of_work.rb', line 12

def acknowledge
  redis_retryable { Queue[queue_name].decrease_busy }
  redis_retryable { Queue[queue_name].release }
end

#requeue ⇒ Object 



17
18
19
20
 
# File 'lib/sidekiq/limit_fetch/unit_of_work.rb', line 17

def requeue
  super
  acknowledge
end