lijian 2 anni fa
parent
commit
8ea2fee76b
1 ha cambiato i file con 5 aggiunte e 4 eliminazioni
  1. 5 4
      pkg/mqtt/connection.go

+ 5 - 4
pkg/mqtt/connection.go

@@ -205,10 +205,11 @@ func (c *Connection) RcvMsgFromClient() {
 				return
 			}
 			args := rpcs.ArgsGetOnline{
-				Id:                device.DeviceIdentifier,
-				ClientIP:          host,
-				AccessRPCHost:     server.GetRPCHost(),
-				HeartbeatInterval: uint32(c.KeepAlive),
+				Id:            device.DeviceIdentifier,
+				ClientIP:      host,
+				AccessRPCHost: server.GetRPCHost(),
+				//HeartbeatInterval: uint32(c.KeepAlive),
+				HeartbeatInterval: 60000,
 			}
 
 			c.Mgr.AddConn(c.DeviceCode, c)