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