consumer: backoffMtx and rdyRetryMtx don't read lock

nsqio · Mar 14, 2019 · cd1b94b · cd1b94b
1 parent 0897cb2
commit cd1b94b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/consumer.go b/consumer.go
@@ -111,11 +111,11 @@ type Consumer struct {
 
 	needRDYRedistributed int32
 
-	backoffMtx sync.RWMutex
+	backoffMtx sync.Mutex
 
 	incomingMessages chan *Message
 
-	rdyRetryMtx    sync.RWMutex
+	rdyRetryMtx    sync.Mutex
 	rdyRetryTimers map[string]*time.Timer
 
 	pendingConnections map[string]*Conn