lib/message_bus/backends/redis.rb in message_bus-2.0.0.beta.3 vs lib/message_bus/backends/redis.rb in message_bus-2.0.0.beta.4

- old
+ new

@@ -25,10 +25,13 @@ end end # max_backlog_size is per multiplexed channel def initialize(redis_config = {}, max_backlog_size = 1000) - @redis_config = redis_config + @redis_config = redis_config.dup + unless @redis_config[:enable_redis_logger] + @redis_config[:logger] = nil + end @max_backlog_size = max_backlog_size @max_global_backlog_size = 2000 @max_publish_retries = 10 @max_publish_wait = 500 #ms @max_in_memory_publish_backlog = 1000