if err = cmd_sock.Bind(cmd_port); err != nil {
panic(err)
}
-
+
cmd_chans = cmd_sock.ChannelsBuffer(10)
go zmqsHandleError(cmd_chans)
} else {
func zmqsHandleError(chans *zmq.Channels) {
for error := range(chans.Errors()) {
chans.Close()
- panic(error)
+ panic(error)
}
}
\ No newline at end of file