fix to close deprecated connections on the reconnect

rabbitmq · Feb 28, 2024 · 7ba88cc · 7ba88cc
1 parent fb560ec
commit 7ba88cc
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/_examples/pubsub/pubsub.go b/_examples/pubsub/pubsub.go
@@ -118,6 +118,7 @@ func publish(sessions chan chan session, messages <-chan message) {
 			select {
 			case confirmed, ok := <-confirm:
 				if !ok {
+					pub.Close()
 					break Publish
 				}
 				if !confirmed.Ack {
@@ -191,6 +192,7 @@ func subscribe(sessions chan chan session, messages chan<- message) {
 			messages <- msg.Body
 			sub.Ack(msg.DeliveryTag, false)
 		}
+		sub.Close()
 	}
 }