module Sidekiq::Addons

Constants

VERSION

Public Class Methods

configure(options={}) click to toggle source
# File lib/sidekiq/addons.rb, line 10
def self.configure(options={})

  #set redis_url to default redis settings if its not passed
  unless options[:redis_url]
    options[:redis_url] = {
      url: 'redis://127.0.0.1:6379/0'
    }
  end

  Sidekiq.configure_client do |config|
    config.client_middleware do |chain|
      chain.add Sidekiq::Addons::Prioritize::Enqr
      config.redis = options[:redis_url]
    end
  end

  Sidekiq.configure_server do |config|
    Sidekiq.options[:fetch] = Sidekiq::Addons::Prioritize::Deqr
    config.redis = options[:redis_url]
    config.client_middleware do |chain|
      chain.add Sidekiq::Addons::Prioritize::Enqr
      config.redis = options[:redis_url]
    end
  end

end