module Sidekiq::Promise

Constants

VERSION

Public Class Methods

included(base) click to toggle source
# File lib/sidekiq/promise.rb, line 15
def self.included(base)
  base.send :include, Sidekiq::Worker unless base.ancestors.member? Sidekiq::Worker
  base.extend(ClassMethods)
  base.send :sidekiq_options, retry: false
  unless MrDarcy.driver == :celluloid
    STDOUT.puts "Switched your MrDarcy driver to Celluloid - it was #{MrDarcy.driver}"
    MrDarcy.driver = :celluloid
  end
end

Public Instance Methods

enable_middleware!() click to toggle source
# File lib/sidekiq/promise.rb, line 32
def enable_middleware!
  raise RuntimeError, "WARNING: Unable to configure required middleware. sidekiq-promise won't work :(" unless Sidekiq.respond_to? :configure_server
  Sidekiq.configure_server do |config|
    config.server_middleware do |chain|
      chain.add Sidekiq::Promise::ServerMiddleware
    end
  end
  Sidekiq.configure_client do |config|
    config.client_middleware do |chain|
      chain.add Sidekiq::Promise::ClientMiddleware
    end
  end
end
redis_pool() click to toggle source
# File lib/sidekiq/promise.rb, line 46
def redis_pool
  @redis_pool ||= Sidekiq::Promise::RedisConnection.create
end