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)
	}
}