test
This commit is contained in:
parent
4a0618dcf5
commit
f73b77e097
7
mq.go
7
mq.go
|
@ -5,16 +5,15 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
func (c *MQClient) Open() error {
|
func (c *MQClient) Open() error {
|
||||||
conn, err := amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path)
|
var err error
|
||||||
c.Connection = conn
|
c.Connection, err = amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
c.Connection.Close()
|
c.Connection.Close()
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
ch, err := c.Connection.Channel()
|
c.Channel, err = c.Connection.Channel()
|
||||||
c.Channel = ch
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
c.Channel.Close()
|
c.Channel.Close()
|
||||||
c.Connection.Close()
|
c.Connection.Close()
|
||||||
|
|
Loading…
Reference in New Issue
Block a user