This commit is contained in:
shoopea 2019-06-28 16:14:10 +08:00
parent 2a26d2f067
commit e70e4677cd

2
mq.go
View File

@ -7,5 +7,5 @@ import (
func (c *MQClient) Open() error {
conn, err := amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path)
c.Connection = conn
return null
return err
}