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