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
      Resque.redis.namespace = "#{Sufia.config.redis_namespace}:#{Rails.env}"
    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

2 entries across 2 versions & 1 rubygems

Version	Path
sufia-models-6.2.0	lib/generators/sufia/models/templates/config/redis_config.rb
sufia-models-6.1.0	lib/generators/sufia/models/templates/config/redis_config.rb