lib/flapjack/processor.rb in flapjack-1.2.0rc1 vs lib/flapjack/processor.rb in flapjack-1.2.0rc2

- old
+ new

@@ -24,10 +24,10 @@ def initialize(opts = {}) @config = opts[:config] @redis_config = opts[:redis_config] || {} @logger = opts[:logger] - @redis = Flapjack::RedisPool.new(:config => @redis_config, :size => 2) + @redis = Flapjack::RedisPool.new(:config => @redis_config, :size => 2, :logger => @logger) @queue = @config['queue'] || 'events' @notifier_queue = @config['notifier_queue'] || 'notifications'