chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
shoopea 2019-07-31 15:03:17 +08:00
parent c5829065c0
commit bc0135f220
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
workers.go
View File

@ -166,6 +166,7 @@ func MQKeepAliveWorker() {
} else if clt, ok := getLockedClient(x.TGUserID64, true); ok { } else if clt, ok := getLockedClient(x.TGUserID64, true); ok {
clt.HeartBeat = x.Date clt.HeartBeat = x.Date
if clt.Active { if clt.Active {
log.Printf("MQKeepAliveWorker : Client already active.\n")
clt.Mux.Unlock() clt.Mux.Unlock()
} else { } else {
log.Printf("MQKeepAliveWorker : Connecting client.\n") log.Printf("MQKeepAliveWorker : Connecting client.\n")