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

test

Browse Source
This commit is contained in:
shoopea 2019-05-17 16:12:51 +08:00
parent b7d240d0e7
commit 9b15c990cc
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
workers.go
View File

@ -325,7 +325,7 @@ func MQTidyKeepAliveWorker() {
t := time.Now()
for _, v := range clientsKeepAlive {
if v.Date.Add(90 * time.Second).Before(time.Now()) {
msgs, err := clientsQueue[v.UserID64].Channel.QueuePurge(clt[v.UserID64].Queue.Name, false)
msgs, err := clientsQueue[v.UserID64].Channel.QueuePurge(clientsQueue[v.UserID64].Queue.Name, false)
_ = clientsQueue[v.UserID64].Channel.Close()
_ = clientsQueue[v.UserID64].Connection.Close()
c := TGCommand{