initialize dummy worker for processing tasks

main.go

@@ -6,6 +6,7 @@ import (
 
 	_ "github.com/joho/godotenv/autoload"
 	"jonasled.dev/jonasled/ems-esp-logger/log"
+	"jonasled.dev/jonasled/ems-esp-logger/messageworker"
 	"jonasled.dev/jonasled/ems-esp-logger/mqttclient"
 	"jonasled.dev/jonasled/ems-esp-logger/mqttserver"
 	"jonasled.dev/jonasled/ems-esp-logger/zeromq"
@@ -21,8 +22,9 @@ func main() {
 		mqttserver.Start()
 	}
 	mqttclient.Init()
+	go messageworker.Run()
 	for {
-		time.Sleep(time.Second)
+		time.Sleep(time.Second) // reduce CPU usage by adding a short sleep here instead of a empty for loop
 	}
 
 }

messageworker/main.go

+package messageworker
+
+import (
+	"fmt"
+	"os"
+
+	zmq "github.com/pebbe/zmq4"
+)
+
+func Run() {
+	worker, _ := zmq.NewSocket(zmq.PULL)
+	defer worker.Close()
+	worker.Connect(os.Getenv("ZEROMQ_WORKER"))
+	for {
+		task, _ := worker.Recv(0)
+		fmt.Println("Processing:", task)
+	}
+}