This commit is contained in:
shoopea 2019-05-03 11:59:57 +08:00
parent a465276246
commit a6cbe5421c

2
mq.go
View File

@ -7,7 +7,7 @@ import (
) )
func MQMainReceive() { 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") failOnError(err, "MQMainReceive : Failed to connect to RabbitMQ")
defer conn.Close() defer conn.Close()