liuxiulin 1 nedēļu atpakaļ
vecāks
revīzija
57228c47d4
1 mainītis faili ar 2 papildinājumiem un 1 dzēšanām
  1. 2 1
      services/emqx-agent/agent.go

+ 2 - 1
services/emqx-agent/agent.go

@@ -62,11 +62,12 @@ func (a *Access) Message(topic string, payload []byte) error {
 	if err != nil {
 		return nil
 	}
-
+	fmt.Printf("topicInfo: %v, message: %v,types:%v,type:%s", topicInfo, jsonPayload, topicInfo.Types, topicInfo.Types[0])
 	switch topicInfo.Types[0] {
 	case "status":
 		return a.processStatus(topicInfo, device.VendorID, jsonPayload)
 	case "event":
+		fmt.Printf("处理事件消息11111111111:----------%s", topicInfo.DeviceCode)
 		return a.processEvent(topicInfo, device.VendorID, jsonPayload)
 	}
 	return nil