From a6cbe5421c9f20798734b0a34f1f465615be2336 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 3 May 2019 11:59:57 +0800 Subject: [PATCH] upd conf --- mq.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mq.go b/mq.go index 9774388..1b010ce 100644 --- a/mq.go +++ b/mq.go @@ -7,7 +7,7 @@ import ( ) func MQMainReceive() { - conn, err := amqp.Dial("amqp://shoopea:UmDd5g4WRa2MzqOHsG2T@localhost:5672/chatwars") + conn, err := amqp.Dial("amqp://" + cfg.Rabbit.User + ":" + cfg.Rabbit.Password + "@" + cfg.Rabbit.Host + "/" + cfg.Rabbit.Queue) failOnError(err, "MQMainReceive : Failed to connect to RabbitMQ") defer conn.Close()