Contents

Sidekiq::LimitFetch::UnitOfWork = Struct.new :queue_wrapper, :message do
  extend Forwardable

  def_delegator :queue_wrapper, :full_name, :queue
  def_delegator :queue_wrapper, :name, :queue_name
  def_delegator :queue_wrapper, :release

  def acknowledge
    release
  end

  def requeue
    release
    Sidekiq.redis {|it| it.rpush queue, message }
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
sidekiq-limit_fetch-0.4	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-0.3	lib/sidekiq/limit_fetch/unit_of_work.rb
sidekiq-limit_fetch-0.2	lib/sidekiq/limit_fetch/unit_of_work.rb