|
@ -149,7 +149,7 @@ func (the *consumerAXYraw) onData(topic string, msg string) bool { |
|
|
|
|
|
|
|
|
needPush := adaptor.Transform(topic, msg) |
|
|
needPush := adaptor.Transform(topic, msg) |
|
|
|
|
|
|
|
|
if needPush != nil { |
|
|
if needPush != nil && len(needPush.Meta) > 0 { |
|
|
//日志标记
|
|
|
//日志标记
|
|
|
if needPush.IotaDevice == logTagDeviceId { |
|
|
if needPush.IotaDevice == logTagDeviceId { |
|
|
bs, _ := json.Marshal(needPush) |
|
|
bs, _ := json.Marshal(needPush) |
|
|