fix one chan block

ysk229 · Mar 17, 2022 · 1335f6a · 1335f6a
1 parent 88f3477
commit 1335f6a
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/producers/producer.go b/producers/producer.go
@@ -73,9 +73,10 @@ func (p *Producer) Producer(m *msg.Message, opts ...ProducerOption) {
 		opt(p)
 	}
 	ch := m.Channel
-	ch.SetConfirmChan(ch.ConfirmOne(make(chan amqp.Confirmation, 1)))
-	ch.SetReturnChan(ch.NotifyReturn(make(chan amqp.Return, 1)))
-	//defer ch.Close()
+	if ch.GetConfirmChan() == nil {
+		ch.SetConfirmChan(ch.ConfirmOne(make(chan amqp.Confirmation, 1)))
+		ch.SetReturnChan(ch.NotifyReturn(make(chan amqp.Return, 1)))
+	}
 	exchangeNum := 0
 	queueNum := 0
 	body := string(m.Body)