run database store multithreaded

messageworker/main.go

@@ -20,18 +20,19 @@ func Run() {
 			continue
 		}
 		log.Log.Debug("Received new task: ", taskData)
+		go func() {
 			var task types.Task
 			err = json.Unmarshal([]byte(taskData), &task)
 			if err != nil {
 				log.Log.Error("Failed decoding task as JSON: ", err.Error())
-			continue
+				return
 			}
 			var instance tables.Instance
 			err = database.Db.Where("name = ?", task.Instance).First(&instance).Error
 			if err != nil {
 				log.Log.Error("Failed retreiving instance from database, pushing task back to queue: ", err.Error())
 				queue.MainQueue.Enqueue(taskData, 60)
-			continue
+				return
 			}
 
 			var jsonData map[string]interface{}
@@ -39,7 +40,7 @@ func Run() {
 			if err != nil {
 				log.Log.Error("Failed decoding boiler JSON: ", err.Error())
 				queue.MainQueue.Enqueue(taskData, 60)
-			continue
+				return
 			}
 			for key, value := range jsonData {
 				valueType := database.GetOrCreateValueType(key)
@@ -52,5 +53,6 @@ func Run() {
 				database.Db.Create(&dbValue)
 			}
 			log.Log.Info("Stored boiler data in database")
+		}()
 	}
 }