ostiwe-com/status
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases 1 Wiki Activity

fix: Recreate closeNotify channel on recreate rabbit connection

Browse Source
This commit is contained in:
Nikolay Anoshin
2025-08-21 13:04:19 +03:00
parent a4050c28dc
commit f5d780fb1b
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/rabbit/connection.go
View File

@@ -87,6 +87,7 @@ func (c *Connection) listenCloseNotify() {
} }
c.conn = dial c.conn = dial
c.closeNotify = dial.NotifyClose(make(chan *amqp.Error))
c.logger.Info("Rabbit connection stabilized") c.logger.Info("Rabbit connection stabilized")