Contents

class Sidekiq::Manager
  module InitLimitFetch
    def initialize(options={})
      options[:fetch] = Sidekiq::LimitFetch
      super
    end

    def start
      Sidekiq::LimitFetch::Queues.start options
      Sidekiq::LimitFetch::Global::Monitor.start!
      super
    end
  end

  prepend InitLimitFetch
end

Version data entries

9 entries across 9 versions & 2 rubygems

Version	Path
sidekiq-limit_fetch-4.1.0	lib/sidekiq/extensions/manager.rb
sidekiq-limit_fetch-4.0.0	lib/sidekiq/extensions/manager.rb
rcgt-sidekiq-limit_fetch-3.4.1	lib/sidekiq/extensions/manager.rb
sidekiq-limit_fetch-3.4.0	lib/sidekiq/extensions/manager.rb
sidekiq-limit_fetch-3.3.1	lib/sidekiq/extensions/manager.rb
sidekiq-limit_fetch-3.3.0	lib/sidekiq/extensions/manager.rb
sidekiq-limit_fetch-3.2.1	lib/sidekiq/extensions/manager.rb
sidekiq-limit_fetch-3.1.0	lib/sidekiq/extensions/manager.rb
sidekiq-limit_fetch-3.0.1	lib/sidekiq/extensions/manager.rb