From 477fad6086029d8c41bdfd54b11a11cff781634f Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Fri, 3 May 2019 15:45:25 +0800
Subject: [PATCH] test

---
 mq.go    | 6 +++---
 utils.go | 6 ++++++
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/mq.go b/mq.go
index 0b7ec7d..2e2f03f 100644
--- a/mq.go
+++ b/mq.go
@@ -44,10 +44,10 @@ func MQMainReceive() {
 		for d := range msgs {
 			log.Printf("MQMainReceive : Received a message: %s", d.Body)
 			if err = json.Unmarshal(d.Body, &m); err != nil {
-				failOnError(err, "MQMainReceive : Can't unmarshal")
+				logOnError(err, "MQMainReceive : Can't unmarshal")
+			} else {
+				putMsg(m)
 			}
-			putMsg(m)
-		}
 	}()
 
 	<-forever
diff --git a/utils.go b/utils.go
index 56154b2..59e408e 100644
--- a/utils.go
+++ b/utils.go
@@ -9,3 +9,9 @@ func failOnError(err error, msg string) {
 		log.Fatalf("%s: %s", msg, err)
 	}
 }
+
+func logOnError(err error, msg string) {
+	if err != nil {
+		log.Printf("%s: %s", msg, err)
+	}
+}