Explorar o código

test: device token

lijian %!s(int64=2) %!d(string=hai) anos
pai
achega
791b5a7b68
Modificáronse 1 ficheiros con 0 adicións e 4 borrados
  1. 0 4
      pkg/mqtt/connection.go

+ 0 - 4
pkg/mqtt/connection.go

@@ -229,10 +229,6 @@ func (c *Connection) RcvMsgFromClient() {
 			server.Log.Infof("device %d, connected to server now, host: %s", c.DeviceID, host)
 
 		case *Publish:
-			if msg.MessageID < c.MessageID {
-				return
-			}
-			c.MessageID = msg.MessageID
 			server.Log.Infof("%s, publish topic: %s, msgId: %v", host, msg.TopicName, msg.MessageID)
 			err = c.Mgr.PublishMessage2Server(c.DeviceCode, c.VendorId, msg)
 			if err != nil {