diff --git a/controller/eventService/Service.go b/controller/eventService/Service.go index 4bda9d109f9beb8cf463a57f2e61069943456a5b..28e992c620aa1a7078ab635ad148020eeada94e1 100644 --- a/controller/eventService/Service.go +++ b/controller/eventService/Service.go @@ -85,6 +85,8 @@ func connect(addr string) (*amqp.Connection, error) { // Will equal two Minuten of retries retries := 60 + logrus.Debugf("will try to connect to: %s", addr) + for i := 0; i < retries; i++ { conn, err := amqp.Dial(addr) if err == nil {