nng.go
@@ -28,6 +28,8 @@ mode Mode url string sendMsg *mangos.Message arguments []interface{} } @@ -49,9 +51,16 @@ time.Sleep(time.Duration(surveyorTime*2) * time.Second) } msg := mangos.NewMessage(len(data)) msg.Body = data return n.sock.SendMsg(msg) // msg := mangos.NewMessage(len(data)) // msg.Body = data // return n.sock.SendMsg(msg) if n.sendMsg == nil { n.sendMsg = &mangos.Message{} n.sendMsg.Header = make([]byte, 32) } n.sendMsg.Body = data return n.sock.SendMsg(n.sendMsg) }