Quellcode durchsuchen

fix(rule): should not open topo when rule has started

Signed-off-by: Jiyong Huang <huangjy@emqx.io>
Jiyong Huang vor 2 Jahren
Ursprung
Commit
e8ddfb4efd
1 geänderte Dateien mit 6 neuen und 4 gelöschten Zeilen
  1. 6 4
      internal/server/rule_manager.go

+ 6 - 4
internal/server/rule_manager.go

@@ -241,10 +241,12 @@ func startRule(name string) error {
 		if err != nil {
 		if err != nil {
 			return err
 			return err
 		}
 		}
-	}
-	err := doStartRule(rs)
-	if err != nil {
-		return err
+		err = doStartRule(rs)
+		if err != nil {
+			return err
+		}
+	} else {
+		conf.Log.Warnf("Rule %s is already started", name)
 	}
 	}
 	return nil
 	return nil
 }
 }