test

2019-05-17 16:33:33 +08:00 · 2019-05-17 16:33:33 +08:00 · da1d3ca910
commit da1d3ca910
parent 584b25be54
1 changed files with 1 additions and 0 deletions
--- a/workers.go
+++ b/workers.go
@ -309,6 +309,7 @@ func MQKeepAliveWorker() {
 				)
 				logOnError(err, "MQKeepAliveWorker : Failed to declare a queue")
 				clientsKeepAlive[x.UserID64] = &x
+				clientsQueue[x.UserID64] = &clt

 				c := TGCommand{
 					Type:       commandSendMsg,