|
@@ -287,8 +287,6 @@ func (c *Connection) RcvMsgFromClient() {
|
|
|
|
|
|
case *Subscribe:
|
|
|
server.Log.Infof("%s, subscribe topic: %v", c.DeviceCode, msg.Topics)
|
|
|
- subAck := SubAck{MessageID: msg.MessageID}
|
|
|
- c.Submit(&subAck)
|
|
|
|
|
|
case *Unsubscribe:
|
|
|
server.Log.Infof("%s, unsubscribe topic: %v", host, msg.Topics)
|