1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
mperham--sidekiq/lib/sidekiq/redis_connection.rb
2012-03-31 12:45:24 -07:00

24 lines
658 B
Ruby

require 'connection_pool'
require 'redis'
require 'redis/namespace'
module Sidekiq
class RedisConnection
def self.create(options={})
url = options[:url] || ENV['REDISTOGO_URL'] || 'redis://localhost:6379/0'
ConnectionPool::Wrapper.new(:timeout => 1, :size => (options[:size] || Sidekiq.options[:concurrency] || 25)) do
build_client(url, options[:namespace])
end
end
def self.build_client(url, namespace)
client = Redis.connect(:url => url)
if namespace
Redis::Namespace.new(namespace, :redis => client)
else
client
end
end
private_class_method :build_client
end
end