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

debug

Browse Source
This commit is contained in:
shoopea 2019-07-31 15:06:16 +08:00
parent aad937f0d6
commit d5ff9a9c4e
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
workers.go
View File

@ -166,10 +166,10 @@ 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") log.Printf("MQKeepAliveWorker : Client %s already active.\n", x.Nickname)
clt.Mux.Unlock() clt.Mux.Unlock()
} else { } else {
log.Printf("MQKeepAliveWorker : Connecting client.\n") log.Printf("MQKeepAliveWorker : Connecting to %s.\n", x.Nickname)
clt.MQ = MQClient{ clt.MQ = MQClient{
User: cfg.Rabbit.User, User: cfg.Rabbit.User,
Password: cfg.Rabbit.Password, Password: cfg.Rabbit.Password,
@ -202,6 +202,7 @@ func MQKeepAliveWorker() {
clt.MQ.Connection.Close() clt.MQ.Connection.Close()
} else { } else {
clt.Active = true clt.Active = true
log.Printf("MQKeepAliveWorker : Connected to %s.\n", x.Nickname)
} }
} }
} }