diff --git a/workers.go b/workers.go
index 8575870..849d50a 100644
--- 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,