| | |
| | | func NewServerWithError(m Mode, url string, args ...interface{}) (Deliver, error) { |
| | | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngServer(m, url, args...), nil |
| | | s := nngServer(m, url, args...) |
| | | if s == nil { |
| | | return nil, errors.New("nng create server error") |
| | | } |
| | | return s, nil |
| | | } else if m == Shm { |
| | | return shmServer(m, url, args...) |
| | | } |
| | |
| | | func NewClientWithError(m Mode, url string, args ...interface{}) (Deliver, error) { |
| | | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngClient(m, url, args...), nil |
| | | s := nngClient(m, url, args...) |
| | | if s == nil { |
| | | return nil, errors.New("nng create client error") |
| | | } |
| | | return s, nil |
| | | } else if m == Shm { |
| | | return shmClient(m, url, args...) |
| | | } |