diff --git a/workers.go b/workers.go index 273d7a6..62f1385 100644 --- a/workers.go +++ b/workers.go @@ -17,13 +17,12 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) { //log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Starting.") var x ChatWarsMessage for true { - c := MQClient{ - User: cfg.Rabbit.User, - Password: cfg.Rabbit.Password, - Host: cfg.Rabbit.Host, - Path: cfg.Rabbit.Path, - SSL: false, - } + c := new(MQClient) + c.User = cfg.Rabbit.User + c.Password = cfg.Rabbit.Password + c.Host = cfg.Rabbit.Host + c.Path = cfg.Rabbit.Path + c.SSL = false err := c.Open()