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:14:23 +08:00
parent 5be31ada11
commit f3b5ce2f14
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
workers.go
View File

@ -326,8 +326,11 @@ func MQTidyKeepAliveWorker() {
for _, v := range clientsKeepAlive { for _, v := range clientsKeepAlive {
if v.Date.Add(90 * time.Second).Before(time.Now()) { if v.Date.Add(90 * time.Second).Before(time.Now()) {
msgs, err := clientsQueue[v.UserID64].Channel.QueuePurge(clientsQueue[v.UserID64].Queue.Name, false) msgs, err := clientsQueue[v.UserID64].Channel.QueuePurge(clientsQueue[v.UserID64].Queue.Name, false)
_ = clientsQueue[v.UserID64].Channel.Close() logOnError(err, "MQTidyKeepAliveWorker : Channel.QueuePurge()")
_ = clientsQueue[v.UserID64].Connection.Close() err = clientsQueue[v.UserID64].Channel.Close()
logOnError(err, "MQTidyKeepAliveWorker : Channel.Close()")
err = clientsQueue[v.UserID64].Connection.Close()
logOnError(err, "MQTidyKeepAliveWorker : Connection.Close()")
c := TGCommand{ c := TGCommand{
Type: commandSendMsg, Type: commandSendMsg,
ToUserID64: v.UserID64, ToUserID64: v.UserID64,