ØMQ/2.2 - The Guide

//
// Pubsub envelope subscriber
//

package main

import (
zmq "github.com/alecthomas/gozmq"
)

func main() {
context, _ := zmq.NewContext()
defer context.Close()

subscriber, _ := context.NewSocket(zmq.SUB)
defer subscriber.Close()
subscriber.Connect("tcp://localhost:5563")
subscriber.SetSockOptString(zmq.SUBSCRIBE, "B")

for {
address, _ := subscriber.Recv(0)
content, _ := subscriber.Recv(0)
print("[" + string(address) + "] " + string(content) + "\n")
}
}