hide internel func

zhangmeng

2019-05-15 f5368c38ae7d538ae37b1fa0444b66a688e299d0

hide internel func

 deliver.go

@@ -14,7 +14,7 @@
func NewProducer(m Mode, url string, args ...interface{}) Deliver {

    if m > ModeStart && m < ModeNNG {
        return NewNNGProducer(m, url, args)
        return nngProducer(m, url, args)
    }
    return nil
}
@@ -23,7 +23,7 @@
func NewConsumer(m Mode, url string, args ...interface{}) Deliver {

    if m > ModeStart && m < ModeNNG {
        return NewNNGConsumer(m, url, args)
        return nngConsumer(m, url, args)
    }

    return nil

 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 {