ZeroMQ test wtf

client.go

package main

import (
	"log"

	zmq "github.com/zeromq/goczmq"
)

func create_dealer() *zmq.Sock {
	dealer, err := zmq.NewDealer("tcp://127.0.0.1:7878")
	if err != nil {
		log.Fatal(err)
	}
	log.Println("dealer created and connected")
	return dealer
}

func send_data(dealer *zmq.Sock, msg []byte) {
	err := dealer.SendFrame(msg, zmq.FlagNone)
	if err != nil {
		log.Fatal(err)
	}
}

func main() {
	dealer := create_dealer()
	// increment this variable to see the WTF
	for i := 0; i < 50; i++ {
		send_data(dealer, []byte("Hello"))
	}
}

serveur.go

package main

import (
	"log"
	"strings"

	zmq "github.com/zeromq/goczmq"
)

func create_router() *zmq.Sock {
	router, err := zmq.NewRouter("tcp://*:7878")
	if err != nil {
		log.Fatal(err)
	}
	log.Println("router created and bound")
	return router
}

func receive_message(router *zmq.Sock) string {
	reply, err := router.RecvMessage()
	if err != nil {
		log.Fatal(err)
	}
	msg := string(reply[1])
	log.Printf("dealer received '%s'", msg)
	return msg
}

func main() {
	var msg string
	router := create_router()
	i := 0
	for {
		msg = receive_message(router)
		i++
		if strings.Compare(msg, "exit") == 0 {
			break
		}
		log.Println(i)
	}
	router.Destroy()
}