瀏覽代碼

fix(rule): update rule state in db when starting

Signed-off-by: Jiyong Huang <huangjy@emqx.io>
Jiyong Huang 2 年之前
父節點
當前提交
21540561ee
共有 1 個文件被更改,包括 6 次插入1 次删除
  1. 6 1
      internal/server/rule_manager.go

+ 6 - 1
internal/server/rule_manager.go

@@ -165,7 +165,12 @@ func startRule(name string) error {
 	if !ok {
 	if !ok {
 		return fmt.Errorf("Rule %s is not found in registry, please check if it is created", name)
 		return fmt.Errorf("Rule %s is not found in registry, please check if it is created", name)
 	} else {
 	} else {
-		return rs.Start()
+		err := rs.Start()
+		if err != nil {
+			return err
+		}
+		err = ruleProcessor.ExecReplaceRuleState(rs.RuleId, true)
+		return err
 	}
 	}
 }
 }