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()