Bring changes from #412

ipfs · Mar 29, 2023 · a5f79a5 · a5f79a5
1 parent d4f0517
commit a5f79a5
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
 	}