diff --git a/iothub/hook_message_work/hook_message_work.go b/iothub/hook_message_work/hook_message_work.go index c32d9a2..cc69b2e 100644 --- a/iothub/hook_message_work/hook_message_work.go +++ b/iothub/hook_message_work/hook_message_work.go @@ -63,6 +63,7 @@ func (s *HookService) handleOne(msg *netbase.DeviceEventInfo) { err = instance.StartRuleChain(context.Background(), ruleMessage) if err != nil { global.Log.Error("规则链执行失败", err) + return } // 保存设备影子 if msg.Type != message.RpcRequestFromDevice { diff --git a/pkg/rule_engine/instance.go b/pkg/rule_engine/instance.go index 4d7b034..f81371b 100644 --- a/pkg/rule_engine/instance.go +++ b/pkg/rule_engine/instance.go @@ -49,7 +49,7 @@ func newInstanceWithManifest(m *manifest.Manifest) (*RuleChainInstance, []error) return r, errs } -// StartRuleChain TODO 是否需要添加context +// StartRuleChain TODO 是否需要添加contexthttp://39.107.143.109/login func (c *RuleChainInstance) StartRuleChain(context context.Context, message *message.Message) error { // 处理debug的通道消息 go func() {