lib/flapjack/coordinator.rb in flapjack-0.6.33 vs lib/flapjack/coordinator.rb in flapjack-0.6.34

@@ -225,15 +225,11 @@
       f.resume
       @logger.debug "new fiber created for #{pikelet_type}"
     end
 
     def build_redis_connection_pool(options = {})
-      redis_em_options = @redis_options.dup
-      redis_db = redis_em_options.delete(:db)
       EventMachine::Synchrony::ConnectionPool.new(:size => options[:size] || 5) do
-        redis = EM::Protocols::Redis.connect(redis_em_options)
-        redis.select(redis_db)
-        redis
+        ::Redis.new(@redis_options)
       end
     end
 
     # # TODO rewrite to be less spammy -- print only initial state and changes
     # def health_check