run message worker for local queue

main.go

@@ -37,6 +37,7 @@ func main() {
 	}
 	if os.Getenv("LOGGER_SERVER") == "true" {
 		server.Init()
+		go messageworker.RunServer()
 		server.Run()
 	} else {
 		log.Log.Fatal("Either LOGGER_CLIENT or LOGGER_SERVER has to be enabled in config")

messageworker/client.go

@@ -17,11 +17,15 @@ func RunClient() {
 	if os.Getenv("CLIENT_USE_SERVER") != "true" {
 
 		log.Log.Info("Intialized local client with direct datbase connection")
-		runLocalDbClient()
+		runDbClient()
 	}
 }
 
-func runLocalDbClient() {
+func RunServer() {
+	runDbClient()
+}
+
+func runDbClient() {
 	for {
 		taskData, taskId, err := queue.MainQueue.Dequeue()
 		if err != nil {