This commit is contained in:
shoopea 2019-06-14 11:29:03 +08:00
parent c92d1867e3
commit dc063c4896

View File

@ -402,7 +402,7 @@ func MQKeepAliveWorker() {
nil, // arguments
)
logOnError(err, "MQKeepAliveWorker : Failed to declare a queue")
clientsKeepAlive.Load(x.UserID64, &x)
clientsKeepAlive.Store(x.UserID64, &x)
clientsQueue[x.UserID64] = &clt
c := TGCommand{