Contents

module Sidekiq
  class Queue
    extend LimitFetch::Singleton, Forwardable
    attr_reader :rname

    def_delegators :lock,
      :limit,         :limit=,         :limit_changed?,
      :process_limit, :process_limit=,
      :acquire,       :release,
      :pause,         :pause_for_ms,   :unpause,
      :block,         :unblock,
      :paused?,       :blocking?,
      :unblocked,     :block_except,
      :probed,        :busy,
      :increase_busy, :decrease_busy,
      :local_busy?,   :explain,
      :remove_locks_except!

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

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sidekiq-limit_fetch-2.4.2	lib/sidekiq/extensions/queue.rb
sidekiq-limit_fetch-2.4.1	lib/sidekiq/extensions/queue.rb