Update queue.go

wolfy-j · web-flow · commit 7353bb7b25ab · 2019-03-25T12:11:14.000+03:00
diff --git a/broker/ephemeral/queue.go b/broker/ephemeral/queue.go
@@ -130,6 +130,7 @@ func (q *queue) stop() {
 	atomic.StoreInt32(&q.active, 0)
 
 	close(q.wait)
+	
 	q.muw.Lock()
 	q.wg.Wait()
 	q.muw.Unlock()	
