diff --git a/bot.go b/bot.go
index ef727b2..a7cf7fa 100644
--- a/bot.go
+++ b/bot.go
@@ -88,7 +88,7 @@ func botMsgRescan(m *tb.Message) (string, error) {
 		}
 		b, _ := json.Marshal(p)
 		log.Printf("botMsgRescan : json : %s\n", string(b))
-		err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanMsg, time.Now(), b)
+		err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanMsg, int64(m.Sender.ID), time.Now(), b)
 		logOnError(err, "botMsgRescan : createJob(objSubTypeJobRescanMsg)")
 		if err != nil {
 			return "Error scheduling the rescan for msg #" + m.Payload, nil
@@ -106,7 +106,7 @@ func botMsgRescan(m *tb.Message) (string, error) {
 		}
 		b, _ := json.Marshal(p)
 		log.Printf("botMsgRescan : json : %s\n", string(b))
-		err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanAllMsg, time.Now(), b)
+		err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanAllMsg, int64(m.Sender.ID), time.Now(), b)
 		logOnError(err, "botMsgRescan : createJob(objSubTypeJobRescanMsg)")
 		if err != nil {
 			return "Error scheduling the rescan for all msg", nil
@@ -130,7 +130,7 @@ func botMsgRescanAll(m *tb.Message) (string, error) {
 	}
 	b, _ := json.Marshal(p)
 	log.Printf("botMsgRescan : json : %s\n", string(b))
-	err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanAllMsg, time.Now(), b)
+	err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanAllMsg, int64(m.Sender.ID), time.Now(), b)
 	logOnError(err, "botMsgRescan : createJob(objSubTypeJobRescanMsg)")
 	if err != nil {
 		return "Error scheduling the rescan for all msg", nil
diff --git a/main.go b/main.go
index 9f87dbc..647a86f 100644
--- a/main.go
+++ b/main.go
@@ -47,7 +47,7 @@ var (
 	cfg                 Config
 	MQCWMsgQueue        chan ChatWarsMessage
 	SQLMsgIdentifyQueue chan int64
-	TGMsgQueue          chan TGCommand
+	TGCmdQueue          chan TGCommand
 	msgParsingRules     map[int]MessageParsingRule
 )