|
@@ -287,13 +287,13 @@ func (c *Connection) RcvMsgFromClient() {
|
|
|
c.Submit(pingrsp)
|
|
|
|
|
|
case *Subscribe:
|
|
|
- server.Log.Infof("%s, subscribe topic: %v", host, msg.Topics)
|
|
|
+ server.Log.Infof("%s, subscribe topic: %v", c.DeviceCode, msg.Topics)
|
|
|
|
|
|
case *Unsubscribe:
|
|
|
server.Log.Infof("%s, unsubscribe topic: %v", host, msg.Topics)
|
|
|
|
|
|
case *Disconnect:
|
|
|
- server.Log.Infof("%s, disconnect now, exit...", host)
|
|
|
+ server.Log.Infof("%s, disconnect now, exit...", c.DeviceCode)
|
|
|
c.Close()
|
|
|
return
|
|
|
|