alpine-test.go

package main

import (
	zmq "github.com/pebbe/zmq4"
	"log"
)

func main() {
	subscriber, _ := zmq.NewSocket(zmq.SUB)
	subscriber.Connect("localhost:1234")
	defer subscriber.Close()

	for {
		msg, err := subscriber.RecvMessage(0)
		if err != nil {
			log.Printf("Failed to recive message: %v", err)
			break
		}
		log.Printf("Msg: %v", msg)
	}
}