From 09ce69f7aaae9babeebd0ce1a994581c698d993b Mon Sep 17 00:00:00 2001
From: Neil Schark <neil.schark@h-da.de>
Date: Wed, 6 Mar 2024 10:32:53 +0000
Subject: [PATCH] wip
---
controller/eventService/Service.go | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/controller/eventService/Service.go b/controller/eventService/Service.go
index 30ecf27ba..97eb159cf 100644
--- a/controller/eventService/Service.go
+++ b/controller/eventService/Service.go
@@ -88,9 +88,10 @@ func connect(addr string) (*amqp.Connection, error) {
for i := 0; i < retries; i++ {
conn, err := amqp.Dial(addr)
if err == nil {
+ logrus.Debug("Connected to RabbitMQ")
return conn, nil
}
- logrus.Info("could not connect to RabbitMQ. Retrying in 2 seconds.")
+ logrus.Error("could not connect to RabbitMQ. Retrying in 2 seconds.")
time.Sleep(2 * time.Second)
}
--
GitLab