diff --git a/controller/metrics/amqpSource.go b/controller/metrics/amqpSource.go
index c7cd66ac..5de51fcb 100644
--- a/controller/metrics/amqpSource.go
+++ b/controller/metrics/amqpSource.go
@@ -47,9 +47,6 @@ func newAmqpSource(cfg *AmqpSourceConfig) (*amqpSource, error) {
 		close: make(chan struct{}),
 		join:  make(chan struct{}),
 	}
-	if err := as.connect(); err != nil {
-		return nil, err
-	}
 	return as, nil
 }