func (p *PublisherZmq) SendMessage(msg []byte, topic string) {
	p.socket.SendBytes([]byte(topic), zmq.SNDMORE)
	p.socket.SendBytes(msg, 0)
}
Publish message via zmq socket
package messengers
import (
	"fmt"
	zmq "github.com/pebbe/zmq4"
)
type PublisherZmq struct {
	socket *zmq.Socket
}