test

mq.go

@@ -47,7 +47,10 @@ func MQMainReceive() {
 			if err = json.Unmarshal(d.Body, &m); err != nil {
 				logOnError(err, "MQMainReceive : Can't unmarshal")
 			} else {
-				putMsg(m)
+				err = putMsg(m)
+				if err != nil {
+					logOnError(err, "MQMainReceive")
+				}
 			}
 		}
 	}()

sql.go

@@ -79,20 +79,18 @@ func initDB() {
 	log.Println("Database set up")
 }
 
-func putMsg(m ChatWarsMessage) {
+func putMsg(m ChatWarsMessage) error {
 	stmt, err := db.Prepare(`INSERT INTO msg	(id, chat_id, user_id, date            , text)
 							 VALUES 			(?,  ?,       ?,       FROM_UNIXTIME(?), ?);`)
 	if err != nil {
-		log.Fatal(err)
+		return err
 	}
+	defer stmt.Close()
 
 	_, err = stmt.Exec(m.MsgID64, m.ChatID64, m.UserID64, m.MsgDate, m.MsgText)
 	if err != nil {
-		log.Fatal(err)
+		return err
 	}
 
-	err = stmt.Close()
-	if err != nil {
-		log.Fatal(err)
-	}
+	return nil
 }