diff --git a/controller/eventService/Service.go b/controller/eventService/Service.go index 30ecf27ba7a7e26af83202928b2947fd6a35c909..97eb159cf34f433f5e31bf4eb8a9dc95021c1c5a 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) }