Sha256: cf2522ad448a628c89b107bc17dbab60c4553ca2df403ceafdb2541f2c2e41ed
Contents?: true
Size: 1.06 KB
Versions: 86
Compression:
Stored size: 1.06 KB
Contents
if defined?(PhusionPassenger)
PhusionPassenger.on_event(:starting_worker_process) do |forked|
# We're in smart spawning mode.
if forked
# Re-establish redis connection
require 'redis'
config = YAML::load(ERB.new(IO.read(File.join(Rails.root, 'config', 'redis.yml'))).result)[Rails.env].with_indifferent_access
# The important two lines
$redis.client.disconnect if $redis
$redis = Redis.new(host: config[:host], port: config[:port], thread_safe: true) rescue nil
Resque.redis = $redis
Resque.redis.client.reconnect if Resque.redis
end
end
else
config = YAML::load(ERB.new(IO.read(File.join(Rails.root, 'config', 'redis.yml'))).result)[Rails.env].with_indifferent_access
$redis = Redis.new(host: config[:host], port: config[:port], thread_safe: true) rescue nil
end
# Code borrowed from Obie's Redis patterns talk at RailsConf'12
Nest.class_eval do
def initialize(key, redis=$redis)
super(key.to_param)
@redis = redis
end
def [](key)
self.class.new("#{self}:#{key.to_param}", @redis)
end
end
Version data entries
86 entries across 86 versions & 5 rubygems