Contents

module Sidekiq
  class Queue
    extend LimitFetch::Singleton, Forwardable
    def_delegators :lock, :limit, :limit=, :acquire, :release, :busy

    def full_name
      @rname
    end

    def lock
      @lock ||= LimitFetch::Semaphore.new
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sidekiq-limit_fetch-0.4	lib/sidekiq/limit_fetch/queue.rb
sidekiq-limit_fetch-0.3	lib/sidekiq/limit_fetch/queue.rb