From 5ea01ae0b3fdd7ce4942e87f936d6364f0610ace Mon Sep 17 00:00:00 2001 From: shoopea Date: Sat, 4 May 2019 11:56:42 +0800 Subject: [PATCH] typo --- mq.go | 1 - 1 file changed, 1 deletion(-) 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()