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, message) ⇒ UnitOfWork
constructor
A new instance of UnitOfWork.
- #requeue ⇒ Object
Constructor Details
#initialize(queue, message) ⇒ 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, ) super 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 Queue[queue_name].decrease_busy 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 |