|
@@ -100,7 +100,7 @@ type MeteData struct {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
func (M *MQTTBrokerNode) OnMessage(ctx ruleEngine.Context, message *protocol.Message) error {
|
|
func (M *MQTTBrokerNode) OnMessage(ctx ruleEngine.Context, message *protocol.Message) error {
|
|
|
-
|
|
|
|
|
|
|
+ fmt.Printf("metedata；%v \r\n", message.MetaData)
|
|
|
var meteData MeteData
|
|
var meteData MeteData
|
|
|
if v, ok := message.MetaData["vendor_id"]; ok {
|
|
if v, ok := message.MetaData["vendor_id"]; ok {
|
|
|
meteData.VendorId = v.(string)
|
|
meteData.VendorId = v.(string)
|
|
@@ -108,8 +108,6 @@ func (M *MQTTBrokerNode) OnMessage(ctx ruleEngine.Context, message *protocol.Mes
|
|
|
if v, ok := message.MetaData["device_id"]; ok {
|
|
if v, ok := message.MetaData["device_id"]; ok {
|
|
|
meteData.DeviceId = v.(string)
|
|
meteData.DeviceId = v.(string)
|
|
|
}
|
|
}
|
|
|
- meteData.VendorId = "lijian"
|
|
|
|
|
- meteData.DeviceId = "deviceId"
|
|
|
|
|
tpl, err := template.New("topic").Parse(defaultTopicTemp)
|
|
tpl, err := template.New("topic").Parse(defaultTopicTemp)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
return err
|
|
return err
|
lijian