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")