class RedisQueue::RedisConnection
Public Class Methods
new(args)
click to toggle source
# File lib/redis_connection.rb, line 4 def initialize(args) @args = args end
Public Instance Methods
new_redis()
click to toggle source
# File lib/redis_connection.rb, line 22 def new_redis ::Redis.new(@args) end
run() { |redis| ... }
click to toggle source
# File lib/redis_connection.rb, line 8 def run @redis ||= new_redis begin yield(@redis) rescue Redis::CannotConnectError, Redis::TimeoutError => e puts e.backtrace puts 'Redis crashed, retrying' sleep 2 @redis = new_redis retry end end