test
This commit is contained in:
parent
f73b77e097
commit
7f3202f35f
2
mq.go
2
mq.go
@ -4,7 +4,7 @@ import (
|
||||
"github.com/streadway/amqp"
|
||||
)
|
||||
|
||||
func (c *MQClient) Open() error {
|
||||
func Open(c *MQClient) error {
|
||||
var err error
|
||||
c.Connection, err = amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path)
|
||||
|
||||
|
@ -25,7 +25,7 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
|
||||
SSL: false,
|
||||
}
|
||||
|
||||
err := c.Open()
|
||||
err := Open(c)
|
||||
|
||||
if err != nil {
|
||||
q, err := c.Channel.QueueDeclare(
|
||||
|
Loading…
Reference in New Issue
Block a user