diff --git a/cmd/mqtt2prometheus.go b/cmd/mqtt2prometheus.go index e2b0156..d2929d7 100644 --- a/cmd/mqtt2prometheus.go +++ b/cmd/mqtt2prometheus.go @@ -49,7 +49,7 @@ func main() { mqttClientOptions.SetUsername(cfg.MQTT.User) mqttClientOptions.SetPassword(cfg.MQTT.Password) - collector := metrics.NewCollector(cfg.Cache.Timeout*time.Minute, cfg.Metrics) + collector := metrics.NewCollector(cfg.Cache.Timeout, cfg.Metrics) ingest := metrics.NewIngest(collector, cfg.Metrics) errorChan := make(chan error,1)