zhangmeng
2019-08-30 4f3bd6a122917eed4b5a5ead80a05ef9c143e395
nng.go
@@ -28,8 +28,6 @@
   mode Mode
   url  string
   sendMsg *mangos.Message
   arguments []interface{}
}
@@ -51,16 +49,9 @@
      time.Sleep(time.Duration(surveyorTime*2) * time.Second)
   }
   // msg := mangos.NewMessage(len(data))
   // msg.Body = data
   // return n.sock.SendMsg(msg)
   if n.sendMsg == nil {
      n.sendMsg = mangos.NewMessage(1)
   }
   n.sendMsg.Body = data
   return n.sock.SendMsg(n.sendMsg)
   msg := mangos.NewMessage(1)
   msg.Body = data
   return n.sock.SendMsg(msg)
}
// Recv impl interface Diliver