fix: ensure we shutdown the message queue asap (#362)

824f7264 · Steven Allen · GitHub · 9fc4a368 · 824f7264
Unverified Commit 824f7264 authored Apr 21, 2020 by Steven Allen Committed by GitHub Apr 21, 2020
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

internal/messagequeue/messagequeue.go internal/messagequeue/messagequeue.go +1 -1

No files found.
--- 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()