nng.go
@@ -49,10 +49,9 @@ time.Sleep(time.Duration(surveyorTime*2) * time.Second) } msg := mangos.NewMessage(len(data)) msg := mangos.NewMessage(1) msg.Body = data return n.sock.SendMsg(msg) } // Recv impl interface Diliver @@ -79,6 +78,13 @@ } // Recv2 impl interface func (n *NNG) Recv2(data []byte) (l int, err error) { data, err = n.Recv() l = len(data) return l, err } // Close impl interface Deliver func (n *NNG) Close() { if n != nil && n.sock != nil {
