1//
2//  Shows how to provoke EAGAIN when reaching HWM
3//
4
5package main
6
7import (
8	zmq "github.com/pebbe/zmq4"
9
10	"fmt"
11)
12
13func main() {
14
15	mailbox, _ := zmq.NewSocket(zmq.DEALER)
16	mailbox.SetSndhwm(4)
17	mailbox.SetSndtimeo(0)
18	mailbox.Connect("tcp://localhost:9876")
19
20	for count := 0; count < 10; count++ {
21		fmt.Println("Sending message", count)
22		_, err := mailbox.SendMessage(fmt.Sprint("message ", count))
23		if err != nil {
24			fmt.Println(err)
25			break
26		}
27	}
28}
29