liuxiulin před 1 týdnem
rodič
revize
256b56f123
1 změnil soubory, kde provedl 1 přidání a 1 odebrání
  1. 1 1
      pkg/protocol/topic.go

+ 1 - 1
pkg/protocol/topic.go

@@ -82,7 +82,7 @@ func parseTopic(topics []string) (topicInfo *TopicInfo, err error) {
 		return nil, errors.New("topic is err")
 	}
 	switch topics[0] {
-	case TopicHeadThing, TopicHeadOta, TopicHeadShadow, TopicHeadLog, TopicHeadConfig, TopicHeadGateway, TopicHeadExt:
+	case TopicHeadThing, TopicHeadOta, TopicHeadShadow, TopicHeadLog, TopicHeadConfig, TopicHeadGateway, TopicHeadExt, TopicHeadEvent:
 		return parseLast(topics)
 	default: //自定义消息
 		return parsePose(0, topics)