From b4082c54f92af4c97e2d73a54b1b8632eae0d35f Mon Sep 17 00:00:00 2001 From: shoopea Date: Wed, 31 Jul 2019 16:02:29 +0800 Subject: [PATCH] test --- workers.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/workers.go b/workers.go index f917a74..410c2b6 100644 --- a/workers.go +++ b/workers.go @@ -77,7 +77,7 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) { for d := range m { var x ChatWarsMessage - // log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Received a message: %s", string(d.Body)) + log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Received a message: %s", string(d.Body)) err = json.Unmarshal(d.Body, &x) logOnError(err, "MQGetMsgWorker["+strconv.Itoa(id)+"] : Can't unmarshal.\n"+string(d.Body)) if err == nil { @@ -315,7 +315,7 @@ func SQLCWMsgWorker(id int, msgs <-chan ChatWarsMessage, objIds chan<- int64) { // log.Printf("SQLCWMsgWorker["+strconv.Itoa(id)+"] : Message inserted (%d).\n", objId) objIds <- objId } else { - log.Printf("SQLCWMsgWorker["+strconv.Itoa(id)+"] : Message in error\n%s\n", m.Text) + //log.Printf("SQLCWMsgWorker["+strconv.Itoa(id)+"] : Message in error\n%s\n", m.Text) } }