add send msg param

zhangmeng

2019-08-30 383557064fd77c028fd71facf8ec1cf6b278d3e6

 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)

}

@@ -82,7 +91,8 @@
// Recv2 impl interface
func (n *NNG) Recv2(data []byte) (l int, err error) {
   data, err = n.Recv()
   return len(data), err
   l = len(data)
   return l, err
}

// Close impl interface Deliver