add close

zhangmeng

2019-05-15 aaae9917c3df122e2bbcf591417c1b58021d79fc

add close

 deliver.go

@@ -8,13 +8,16 @@

    // Recv recv data
    Recv() ([]byte, error)

    // Close close Deliver
    Close()
}

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

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

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

    return nil

 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 {