src/cmd/worker/main.go

@@ -105,7 +105,7 @@ func main() {
 		for d := range msgs {
 			msg, err := amqp.Deserialize(d.Body)
 			if err != nil {
-				logger.Log("json error:", err)
+				logger.Log("json error: %v\n", err)
 				d.Reject(false) // FIXME: how to handle erros in queue...????
 				continue
 			}