diff --git a/main.go b/main.go
index f78c84c..045b8ce 100644
--- a/main.go
+++ b/main.go
@@ -50,7 +50,7 @@ var (
 	TGCmdQueue          chan TGCommand
 	MQTGCmdQueue        chan TGCommand
 	msgParsingRules     map[int]MessageParsingRule
-	clientsQueues       map[int64]MQKeepAlive
+	clientsQueues       map[int64]*MQKeepAlive
 )
 
 func PrintText(m *tb.Message) {
@@ -108,7 +108,7 @@ func main() {
 	SQLMsgIdentifyQueue = make(chan int64, 100)
 	TGCmdQueue = make(chan TGCommand, 100)
 	MQTGCmdQueue = make(chan TGCommand, 100)
-	clientsQueues = make(map[int64]MQKeepAlive)
+	clientsQueues = make(map[int64]*MQKeepAlive)
 
 	for w := 1; w <= MQGetMsgWorkers; w++ {
 		go MQGetMsgWorker(w, MQCWMsgQueue)