lib/flapjack/coordinator.rb in flapjack-0.6.31 vs lib/flapjack/coordinator.rb in flapjack-0.6.32

@@ -225,11 +225,15 @@
       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.new(@redis_options.merge(:driver => (options[:driver] || 'synchrony')))
+        redis = EM::Protocols::Redis.connect(redis_em_options)
+        redis.select(redis_db)
+        redis
       end
     end
 
     # # TODO rewrite to be less spammy -- print only initial state and changes
     # def health_check