Contents

module Sidekiq
  class LimitFetch::UnitOfWork < BasicFetch::UnitOfWork
    def acknowledge
      Queue[queue_name].release
    end

    def requeue
      super
      acknowledge
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
sidekiq-limit_fetch-1.6	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-1.5	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-1.4	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-1.3	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-1.2	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-1.1	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-1.0	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-0.9	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-0.8	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-0.7	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-0.6	lib/sidekiq/limit_fetch/unit_of_work.rb