package msg import ( "encoding/json" "plc-recorder/config" "plc-recorder/logger" "plc-recorder/nsqclient" ) func SendDeviceLiveData(response *PLCResponse) { logger.Debug("plc live data: %+v", response) b, _ := json.Marshal(response) nsqclient.Produce(config.Options.PLCDataTopic, b) }