fix: Recreate closeNotify channel on recreate rabbit connection

2025-08-21 13:04:19 +03:00
parent a4050c28dc
commit f5d780fb1b
1 changed files with 1 additions and 0 deletions
--- a/pkg/rabbit/connection.go
+++ b/pkg/rabbit/connection.go
@@ -87,6 +87,7 @@ func (c *Connection) listenCloseNotify() {
 			}

 			c.conn = dial
+			c.closeNotify = dial.NotifyClose(make(chan *amqp.Error))

 			c.logger.Info("Rabbit connection stabilized")