test

bot.go

@@ -121,8 +121,8 @@ func botMsgRescan(m *tb.Message) {
 			TGCmdQueue <- c
 		} else {
 			c := TGCommand{
-				Type: commandReplyMsg,
-				Text: fmt.Sprint("Rescaning msg #%s", m.Payload), "Rescaning all msg scheduled.",
+				Type:         commandReplyMsg,
+				Text:         fmt.Sprint("Rescaning msg #%s", m.Payload),
 				FromMsgID64:  int64(m.ID),
 				FromChatID64: m.Chat.ID,
 			}

workers.go

@@ -242,7 +242,7 @@ func MQTGCmdWorker(id int, cmds <-chan TGCommand) {
 				false,                                   // immediate
 				amqp.Publishing{
 					ContentType: "application/json",
-					Body:        []byte(b),
+					Body:        []byte(j),
 				})
 			logOnError(err, "MQTGCmdWorker["+strconv.Itoa(id)+"] : Publishing message.")
 		}