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