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

• #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.

# File 'lib/sidekiq/limit_fetch/unit_of_work.rb', line 3

def initialize(queue, job)
  super
  Queue[queue_name].increase_busy
end

Instance Method Details

#acknowledge ⇒ Object

# 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

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

def requeue
  super
  acknowledge
end