use mangos msgchache

zhangmeng

2019-08-30 971bd16379d411f93eef96f935b9ad92c372569f

 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
@@ -82,7 +81,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