test: 打印

pkg/ruleEngine/nodes/mqtt_broker_node.go

@@ -108,6 +108,8 @@ func (M *MQTTBrokerNode) OnMessage(ctx ruleEngine.Context, message *protocol.Mes
 	if v, ok := message.MetaData["device_id"]; ok {
 		meteData.DeviceId = v.(string)
 	}
+	meteData.VendorId = "lijian"
+	meteData.DeviceId = "deviceId"
 	tpl, err := template.New("topic").Parse(defaultTopicTemp)
 	if err != nil {
 		return err