|
@@ -229,7 +229,7 @@ func (c *Connection) RcvMsgFromClient() {
|
|
|
server.Log.Infof("device %d, connected to server now, host: %s", c.DeviceID, host)
|
|
server.Log.Infof("device %d, connected to server now, host: %s", c.DeviceID, host)
|
|
|
|
|
|
|
|
case *Publish:
|
|
case *Publish:
|
|
|
- server.Log.Infof("%s, publish topic: %s", host, msg.TopicName)
|
|
|
|
|
|
|
+ server.Log.Infof("%s, publish topic: %s， msgId: %v", host, msg.TopicName, msg.MessageID)
|
|
|
err = c.Mgr.PublishMessage2Server(c.DeviceCode, c.VendorId, msg)
|
|
err = c.Mgr.PublishMessage2Server(c.DeviceCode, c.VendorId, msg)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
server.Log.Errorf("PublishMessage2Server error:%s", err.Error())
|
|
server.Log.Errorf("PublishMessage2Server error:%s", err.Error())
|
lijian