upd

main.go

@@ -51,7 +51,8 @@ var (
 
 	db *sql.DB
 
-	cfg Config
+	cfg          Config
+	MQCWMsgQueue chan ChatWarsMessage
 )
 
 func PrintText(m *tb.Message) {
@@ -94,7 +95,11 @@ func main() {
 	}
 
 	go StartBot()
-	go MQMainReceive()
+
+	MQCWMsgQueue = make(chan ChatWarsMessage, 100)
+	for w := 1; w <= 3; w++ {
+		go MQGetMsg(w, MQCWMsgQueue)
+	}
 
 	fmt.Println("Started !")
 

mq.go

@@ -3,6 +3,7 @@ package main
 import (
 	"encoding/json"
 	"log"
+	"strconv"
 
 	"github.com/streadway/amqp"
 )