change name

zhangmeng

2019-05-16 e6cfa59401d45f74a2815d33b62e22e02765d94e

change name

 deliver.go

@@ -13,20 +13,20 @@
    Close()
}

// NewListener create listener args presentive for parameter with protocal, e.g. sub topic
func NewListener(m Mode, url string, args ...interface{}) Deliver {
// NewPush create listener args presentive for parameter with protocal, e.g. sub topic
func NewPush(m Mode, url string, args ...interface{}) Deliver {

    if m > ModeStart && m < ModeNNG {
        return nngListener(m, url, args...)
        return nngPush(m, url, args...)
    }
    return nil
}

// NewDialer create dialer args presentive for parameter with protocal, e.g. sub topic
func NewDialer(m Mode, url string, args ...interface{}) Deliver {
// NewPull create dialer args presentive for parameter with protocal, e.g. sub topic
func NewPull(m Mode, url string, args ...interface{}) Deliver {

    if m > ModeStart && m < ModeNNG {
        return nngDialer(m, url, args...)
        return nngPull(m, url, args...)
    }

    return nil

 nng.go

@@ -70,7 +70,7 @@
    }
}

func nngListener(m Mode, url string, args ...interface{}) *NNG {
func nngPush(m Mode, url string, args ...interface{}) *NNG {

    rmExistedIpcName(url)
    if sock, err := newSocket(protoProducer(m)); err == nil {
@@ -93,7 +93,7 @@
    return nil
}

func nngDialer(m Mode, url string, args ...interface{}) *NNG {
func nngPull(m Mode, url string, args ...interface{}) *NNG {

    if sock, err := newSocket(protoConsumer(m)); err == nil {
        if err = setSocketOptions(sock, args); err != nil {