add close

zhangmeng

2019-05-15 aaae9917c3df122e2bbcf591417c1b58021d79fc

 nng.go

@@ -58,6 +58,13 @@
   return n.sock.Recv()
}

// Close impl interface Deliver
func (n *NNG) Close() {
   if n.sock != nil {
      n.sock.Close()
   }
}

// nngProducer create from deliver Mode
func nngProducer(m Mode, url string, args ...interface{}) *NNG {

@@ -119,7 +126,11 @@
      sock.Close()
      return err
   }
   // if err = sock.SetOption(mangos.OptionNoDelay, true); err != nil {
   // if err = sock.SetOption(mangos.OptionRecvDeadline, time.Second); err != nil {
   //    sock.Close()
   //    return err
   // }
   // if err = sock.SetOption(mangos.OptionSendDeadline, time.Second); err != nil {
   //    sock.Close()
   //    return err
   // }