diff --git a/workers.go b/workers.go index d3bd41e..9a9c5a9 100644 --- a/workers.go +++ b/workers.go @@ -14,6 +14,7 @@ import ( func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) { //log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Starting.") + var x ChatWarsMessage s := MQSession{ User: cfg.Rabbit.User, Password: cfg.Rabbit.Password, @@ -54,7 +55,6 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) { false, // no-wait nil, // args ) - var x ChatWarsMessage for d := range m { log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Received a message: %s", string(d.Body)) err = json.Unmarshal(d.Body, &x)