Bring changes from #412

ipfs · Mar 28, 2023 · 56e9bb6 · 56e9bb6
1 parent bb774cf
commit 56e9bb6
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/messagequeue/messagequeue.go b/messagequeue/messagequeue.go
@@ -248,6 +248,11 @@ func (mq *MessageQueue) sendMessage() {
 		log.Infof("cant open message sender to peer %s: %s", mq.p, err)
 		// TODO: cant connect, what now?
 		mq.publishError(metadata, fmt.Errorf("cant open message sender to peer %s: %w", mq.p, err))
+		select {
+		case <-mq.done:
+		default:
+			mq.Shutdown()
+		}
 		return
 	}