Update queue.go

spiral-modules · Feb 12, 2019 · eb7519b · eb7519b
1 parent 14df7a3
commit eb7519b
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/broker/ephemeral/queue.go b/broker/ephemeral/queue.go
@@ -129,10 +129,11 @@ func (q *queue) stop() {
 
 	atomic.StoreInt32(&q.active, 0)
 
-	close(q.wait)
 	q.muw.Lock()
-	q.wg.Wait()
+	close(q.wait)
 	q.muw.Unlock()
+
+	q.wg.Wait()
 }
 
 // add job to the queue