diff --git a/mq.go b/mq.go index ae76b7d..81b66ec 100644 --- a/mq.go +++ b/mq.go @@ -9,7 +9,6 @@ import ( ) func MQSendMsgWorker(id int, msgs <-chan ChatWarsMessage) { - var x ChatWarsMessage conn, err := amqp.Dial("amqp://" + cfg.Rabbit.User + ":" + cfg.Rabbit.Password + "@" + cfg.Rabbit.Host + "/" + cfg.Rabbit.Queue) failOnError(err, "MQSendMsgWorker["+strconv.Itoa(id)+"] : Failed to connect to RabbitMQ") defer conn.Close()