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)
+	}
+}