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'