From f5d780fb1b682aa1f6f29b9297ed1e3e22ad15e1 Mon Sep 17 00:00:00 2001 From: ostiwe Date: Thu, 21 Aug 2025 13:04:19 +0300 Subject: [PATCH] fix: Recreate closeNotify channel on recreate rabbit connection --- pkg/rabbit/connection.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/rabbit/connection.go b/pkg/rabbit/connection.go index 63c5fc1..2fba784 100644 --- 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")