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 ⇒ UnitOfWork constructor

  A new instance of UnitOfWork.

• #requeue ⇒ Object

Constructor Details

#initialize ⇒ UnitOfWork

Returns a new instance of UnitOfWork.

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

def initialize(...)
  super
  redis_retryable { Queue[queue_name].increase_busy }
end

Instance Method Details

#acknowledge ⇒ Object

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

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

#requeue ⇒ Object

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

def requeue
  super
  acknowledge
end