diff --git a/iothub/client/mqttclient/rpc.go b/iothub/client/mqttclient/rpc.go index 000a8f3..a15c8bd 100644 --- a/iothub/client/mqttclient/rpc.go +++ b/iothub/client/mqttclient/rpc.go @@ -37,7 +37,7 @@ func (rpc RpcRequest) Pub(deviceId, reqPayload string) error { topic := fmt.Sprintf(RpcRespTopic, rpc.RequestId) value, ok := Session.Load(deviceId) if !ok { - return errors.New("为获取到设备的MQTT连接") + return errors.New("未获取到设备的MQTT连接") } return Publish(topic, value.(string), reqPayload) } diff --git a/iothub/client/tcpclient/tcp.go b/iothub/client/tcpclient/tcp.go index 3a82420..6bc57ed 100644 --- a/iothub/client/tcpclient/tcp.go +++ b/iothub/client/tcpclient/tcp.go @@ -20,7 +20,7 @@ func Send(deviceId, msg string) error { } } else { global.Log.Infof("设备%s TCP连接不存在, 发送指令失败", deviceId) - return errors.New("为获取到设备的MQTT连接") + return errors.New("未获取到设备的MQTT连接") } return nil }