Browse Source

完成对组件生命周期的处理

lijian 4 năm trước cách đây
mục cha
commit
ff946c6832
2 tập tin đã thay đổi với 2 bổ sung0 xóa
  1. 1 0
      pkg/actors/app_actor.go
  2. 1 0
      pkg/actors/rule_node_actor.go

+ 1 - 0
pkg/actors/app_actor.go

@@ -76,6 +76,7 @@ func (a *AppActor) onComponentLifeCycleMsg(msg *ruleEngine.ComponentLifecycleMsg
 	} else {
 		server.Log.Debugf("invalid component lifecycle msg %s:", msg.TenantId)
 	}
+	return nil
 }
 
 func (a *AppActor) initTenants() error {

+ 1 - 0
pkg/actors/rule_node_actor.go

@@ -188,6 +188,7 @@ func (r *RuleNodeActor) stop() error {
 	if r.node != nil {
 		r.state = ruleEngine.SUSPENDED
 	}
+	return nil
 }
 
 type RuleNodeActorCreator struct {