Contents

require 'sidekiq/limit_fetch'

RSpec.configure do |config|
  config.before :each do
    Sidekiq::Queue.instance_variable_set :@instances, {}
    Sidekiq.options[:global] = defined?(global) ? global : nil
  
    Sidekiq.redis do |it|
      clean_redis = ->(queue) do
        it.del "limit_fetch:limit:#{queue}"
        it.del "limit_fetch:busy:#{queue}"
        it.del "limit_fetch:pause:#{queue}"
        it.del "limit_fetch:block:#{queue}"
      end

      clean_redis.call(name) if defined?(name)
      queues.each(&clean_redis) if defined?(queues) and queues.is_a? Array
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
sidekiq-limit_fetch-1.4	spec/spec_helper.rb
sidekiq-limit_fetch-1.3	spec/spec_helper.rb
sidekiq-limit_fetch-1.2	spec/spec_helper.rb
sidekiq-limit_fetch-1.1	spec/spec_helper.rb
sidekiq-limit_fetch-1.0	spec/spec_helper.rb
sidekiq-limit_fetch-0.9	spec/spec_helper.rb