This commit is contained in:
PandaGoAdmin
2023-03-22 08:56:56 +08:00
parent 34726c31ff
commit 9412d99d30

View File

@@ -79,7 +79,7 @@ func newInstanceWithManifest(m *manifest.Manifest) (*ruleChainInstance, []error)
return r, errs
}
// StartRuleChain TODO 是否需要添加context
// StartRuleChain
func (c *ruleChainInstance) StartRuleChain(context context.Context, message message.Message) error {
if node, found := c.nodes[c.firstRuleNodeId]; found {
go node.Handle(message)