wip

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