|
@@ -120,8 +120,8 @@ func (M *MQTTBrokerNode) OnMessage(ctx ruleEngine.Context, message *protocol.Mes
|
|
|
return nil
|
|
return nil
|
|
|
}
|
|
}
|
|
|
topic := stringBuf.String()
|
|
topic := stringBuf.String()
|
|
|
- token := M.mqttClient.Publish(topic, 0, false, message.Data)
|
|
|
|
|
fmt.Printf("+++++++++++++++%v\r\n", M.mqttClient)
|
|
fmt.Printf("+++++++++++++++%v\r\n", M.mqttClient)
|
|
|
|
|
+ token := M.mqttClient.Publish(topic, 0, false, message.Data)
|
|
|
if token.Error() != nil {
|
|
if token.Error() != nil {
|
|
|
ctx.TellNext(message, protocol.Failure)
|
|
ctx.TellNext(message, protocol.Failure)
|
|
|
} else {
|
|
} else {
|
lijian