Missed q.lock.Unlock() will cause panic (#9706)

4 years ago · 0e53a16cca
parent 7eaba6ba8a
commit 0e53a16cca
1 changed files with 0 additions and 1 deletions
--- a/modules/queue/queue_wrapped.go
+++ b/modules/queue/queue_wrapped.go
@ -62,7 +62,6 @@ func (q *delayedStarter) setInternal(atShutdown func(context.Context, func()), h
 			queue, err := NewQueue(q.underlying, handle, q.cfg, exemplar)
 			if err == nil {
 				q.internal = queue
-				q.lock.Unlock()
 				break
 			}
 			if err.Error() != "resource temporarily unavailable" {