Revert "test"

This reverts commit 51102e96d3.
2019-06-28 15:54:39 +08:00 · 2019-06-28 15:54:39 +08:00 · ff8aa3b34d
commit ff8aa3b34d
parent 2a5ea917cb
1 changed files with 1 additions and 1 deletions
--- 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)