From 6621887364b1175e6dd1480ef6abae847235b64b Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 3 May 2019 15:46:33 +0800 Subject: [PATCH] test --- mq.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/mq.go b/mq.go index 2e2f03f..7aedf9a 100644 --- a/mq.go +++ b/mq.go @@ -43,11 +43,13 @@ func MQMainReceive() { go func() { for d := range msgs { log.Printf("MQMainReceive : Received a message: %s", d.Body) + if err = json.Unmarshal(d.Body, &m); err != nil { logOnError(err, "MQMainReceive : Can't unmarshal") } else { putMsg(m) } + } }() <-forever