| | |
| | | Close() |
| | | } |
| | | |
| | | // NewListener create listener args presentive for parameter with protocal, e.g. sub topic |
| | | func NewListener(m Mode, url string, args ...interface{}) Deliver { |
| | | // NewServer create listener args presentive for parameter with protocal, e.g. sub topic |
| | | func NewServer(m Mode, url string, args ...interface{}) Deliver { |
| | | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngListener(m, url, args...) |
| | | return nngServer(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 { |
| | | // NewClient create dialer args presentive for parameter with protocal, e.g. sub topic |
| | | func NewClient(m Mode, url string, args ...interface{}) Deliver { |
| | | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngDialer(m, url, args...) |
| | | return nngClient(m, url, args...) |
| | | } |
| | | |
| | | return nil |