Sha256: fb0498db8710fecb858f5be75a034397bcd4e8e2b00b8b3a56df8a5085748ada
Contents?: true
Size: 328 Bytes
Versions: 22
Compression:
Stored size: 328 Bytes
Contents
module Sidekiq
class LimitFetch::UnitOfWork < BasicFetch::UnitOfWork
def initialize(queue, message)
super
Queue[queue_name].increase_busy
end
def acknowledge
Queue[queue_name].decrease_busy
Queue[queue_name].release
end
def requeue
super
acknowledge
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems