zhangmeng
2019-05-15 f5368c38ae7d538ae37b1fa0444b66a688e299d0
nng.go
@@ -51,8 +51,8 @@
   return n.sock.Recv()
}
// NewNNGProducer create from deliver Mode
func NewNNGProducer(m Mode, url string, args ...interface{}) *NNG {
// nngProducer create from deliver Mode
func nngProducer(m Mode, url string, args ...interface{}) *NNG {
   rmExistedIpcName(url)
   if sock, err := newSocket(protoProducer(m)); err == nil {
@@ -71,8 +71,8 @@
   return nil
}
// NewNNGConsumer create from deliver Mode
func NewNNGConsumer(m Mode, url string, args ...interface{}) *NNG {
// nngConsumer create from deliver Mode
func nngConsumer(m Mode, url string, args ...interface{}) *NNG {
   if sock, err := newSocket(protoConsumer(m)); err == nil {
      if err = setSocketOptions(sock, args); err != nil {