zmqchan provides an idiomatic channels interface for go to zeromq
A library to provide channels for the Go interface to ZeroMQ version 4.
Keywords: zmq, zeromq, 0mq, networks, distributed computing, message passing, fanout, pubsub, pipeline, request-reply
zmqchan provides a zmqchan.ChannelPair class which wraps a zmq.Socket into a TX and RX channel.
Currently zmq.Sockets are not threadsafe. These are difficulty to use in combination with golang channels as you can poll on a set of sockets, or select on a set of channels, but not both. This creates problems if you want to use conventional go idioms, e.g. using a chan bool for ending goroutines.
This library provides a means of wrapping a zmq.Socket into a zmq.ChannelPair, which provides an Rx and Tx channel (as well as an error channel). This is loosely based on the idea of the go-zmq binding by vaughan0 but works with ZMQ 4.x.
This is currently lightly tested / experimental.
go get github.com/abligh/zmqchan