Browse Source

fix: message id

lijian 2 years ago
parent
commit
d6752f2531
1 changed files with 1 additions and 1 deletions
  1. 1 1
      pkg/mqtt/connection.go

+ 1 - 1
pkg/mqtt/connection.go

@@ -125,7 +125,7 @@ func (c *Connection) Close() {
 	c.mLock.Lock()
 	defer c.mLock.Unlock()
 	DeviceID := c.DeviceID
-	c.MessageID = 1
+	c.MessageID = 0
 	server.Log.Infof("closing connection of device %v", DeviceID)
 	if c.Conn != nil {
 		c.Conn.Close()