consumer logger: Add set level.

nsqio · Oct 9, 2019 · 48e321c · 48e321c
1 parent 0455293
commit 48e321c
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/consumer.go b/consumer.go
@@ -223,6 +223,13 @@ func (r *Consumer) SetLogger(l logger, lvl LogLevel) {
 	r.logLvl = lvl
 }
 
+func (r *Consumer) SetLoggerLevel(lvl LogLevel) {
+	r.logGuard.Lock()
+	defer r.logGuard.Unlock()
+
+	r.logLvl = lvl
+}
+
 func (r *Consumer) getLogger() (logger, LogLevel) {
 	r.logGuard.RLock()
 	defer r.logGuard.RUnlock()