Class: Sidekiq::LimitFetch::UnitOfWork
- Inherits:
-
BasicFetch::UnitOfWork
- Object
- BasicFetch::UnitOfWork
- Sidekiq::LimitFetch::UnitOfWork
- Defined in:
- lib/sidekiq/limit_fetch/unit_of_work.rb
Instance Method Summary collapse
- #acknowledge ⇒ Object
-
#initialize(queue, job) ⇒ UnitOfWork
constructor
A new instance of UnitOfWork.
- #requeue ⇒ Object
Constructor Details
#initialize(queue, job) ⇒ UnitOfWork
Returns a new instance of UnitOfWork.
3 4 5 6 |
# File 'lib/sidekiq/limit_fetch/unit_of_work.rb', line 3 def initialize(queue, job) super redis_retryable { Queue[queue_name].increase_busy } end |
Instance Method Details
#acknowledge ⇒ Object
8 9 10 11 |
# 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 ⇒ Object
13 14 15 16 |
# File 'lib/sidekiq/limit_fetch/unit_of_work.rb', line 13 def requeue super acknowledge end |