From 824f7264ea9289fac57e598906eecfeb3bc42d6e Mon Sep 17 00:00:00 2001
From: Steven Allen <steven@stebalien.com>
Date: Tue, 21 Apr 2020 11:48:45 -0700
Subject: [PATCH] fix: ensure we shutdown the message queue asap (#362)

---
 internal/messagequeue/messagequeue.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/messagequeue/messagequeue.go b/internal/messagequeue/messagequeue.go
index 7bcc087..ad85e52 100644
--- a/internal/messagequeue/messagequeue.go
+++ b/internal/messagequeue/messagequeue.go
@@ -333,7 +333,7 @@ func (mq *MessageQueue) runQueue() {
 	}
 
 	var workScheduled time.Time
-	for {
+	for mq.ctx.Err() == nil {
 		select {
 		case <-mq.rebroadcastTimer.C:
 			mq.rebroadcastWantlist()
-- 
GitLab