| | |
| | | Close() |
| | | } |
| | | |
| | | // NewProducer create producer args presentive for parameter with protocal, e.g. sub topic |
| | | func NewProducer(m Mode, url string, args ...interface{}) Deliver { |
| | | // NewListener create listener args presentive for parameter with protocal, e.g. sub topic |
| | | func NewListener(m Mode, url string, args ...interface{}) Deliver { |
| | | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngProducer(m, url, args...) |
| | | return nngListener(m, url, args...) |
| | | } |
| | | return nil |
| | | } |
| | | |
| | | // NewConsumer create consumer args presentive for parameter with protocal, e.g. sub topic |
| | | func NewConsumer(m Mode, url string, args ...interface{}) Deliver { |
| | | // NewDialer create dialer args presentive for parameter with protocal, e.g. sub topic |
| | | func NewDialer(m Mode, url string, args ...interface{}) Deliver { |
| | | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngConsumer(m, url, args...) |
| | | return nngDialer(m, url, args...) |
| | | } |
| | | |
| | | return nil |