From ff8aa3b34d1c3fb13ea6745b965c797e4b9265cd Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 15:54:39 +0800 Subject: [PATCH] Revert "test" This reverts commit 51102e96d3371c4c7f2ebc31c29a4849002d0899. --- workers.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)