|
|
@@ -100,7 +100,6 @@ type MeteData struct {
|
|
|
}
|
|
|
|
|
|
func (M *MQTTBrokerNode) OnMessage(ctx ruleEngine.Context, message *protocol.Message) error {
|
|
|
- fmt.Printf("metedata；%v \r\n", message.MetaData)
|
|
|
var meteData MeteData
|
|
|
if v, ok := message.MetaData["vendor_id"]; ok {
|
|
|
meteData.VendorId = v.(string)
|
|
|
@@ -117,7 +116,6 @@ func (M *MQTTBrokerNode) OnMessage(ctx ruleEngine.Context, message *protocol.Mes
|
|
|
return nil
|
|
|
}
|
|
|
topic := stringBuf.String()
|
|
|
- fmt.Println(topic)
|
|
|
token := M.mqttClient.Publish(topic, 0, false, message.Data)
|
|
|
if token.Error() != nil {
|
|
|
ctx.TellNext(message, protocol.Failure)
|
lijian